package o; import android.text.Editable; import android.text.TextWatcher; import android.widget.TextView; /* loaded from: classes3.dex */ public final class CAq extends AbstractC0998Thl { private final TextView e; @Override // o.AbstractC0998Thl public final /* synthetic */ CharSequence e() { return this.e.getText(); } public CAq(TextView textView) { C14957gcv.b((Object) textView, ""); this.e = textView; } @Override // o.AbstractC0998Thl public final void a(InterfaceC13174fSv interfaceC13174fSv) { C14957gcv.b((Object) interfaceC13174fSv, ""); LWm lWm = new LWm(this.e, interfaceC13174fSv); interfaceC13174fSv.onSubscribe(lWm); this.e.addTextChangedListener(lWm); } /* loaded from: classes3.dex */ static final class LWm extends fRS implements TextWatcher { private final TextView d; private final InterfaceC13174fSv e; public LWm(TextView textView, InterfaceC13174fSv interfaceC13174fSv) { C14957gcv.b((Object) textView, ""); C14957gcv.b((Object) interfaceC13174fSv, ""); this.d = textView; this.e = interfaceC13174fSv; } @Override // android.text.TextWatcher public final void onTextChanged(CharSequence charSequence, int i, int i2, int i3) { C14957gcv.b((Object) charSequence, ""); if (isDisposed()) { return; } this.e.onNext(charSequence); } @Override // o.fRS public final void b() { this.d.removeTextChangedListener(this); } @Override // android.text.TextWatcher public final void beforeTextChanged(CharSequence charSequence, int i, int i2, int i3) { C14957gcv.b((Object) charSequence, ""); } @Override // android.text.TextWatcher public final void afterTextChanged(Editable editable) { C14957gcv.b((Object) editable, ""); } } }