25 lines
683 B
Java
25 lines
683 B
Java
package o;
|
|
|
|
/* loaded from: classes6.dex */
|
|
public final class fTQ<T> extends AbstractC13211fTy implements InterfaceC13174fSv<T> {
|
|
private fSQ<? super T> b;
|
|
|
|
public fTQ(InterfaceC13145fSF interfaceC13145fSF, fSQ<? super T> fsq, fSQ<? super Throwable> fsq2, fSP fsp) {
|
|
super(interfaceC13145fSF, fsq2, fsp);
|
|
this.b = fsq;
|
|
}
|
|
|
|
@Override // o.InterfaceC13174fSv
|
|
public final void onNext(T t) {
|
|
if (get() != EnumC13192fTf.DISPOSED) {
|
|
try {
|
|
this.b.c(t);
|
|
} catch (Throwable th) {
|
|
C13147fSI.c(th);
|
|
get().dispose();
|
|
onError(th);
|
|
}
|
|
}
|
|
}
|
|
}
|