63 lines
1.8 KiB
Java
63 lines
1.8 KiB
Java
package o;
|
|
|
|
/* renamed from: o.fWj, reason: case insensitive filesystem */
|
|
/* loaded from: classes6.dex */
|
|
public final class C13301fWj<T> extends AbstractC13163fSk<T> {
|
|
private InterfaceC15340gnp<? extends T> e;
|
|
|
|
public C13301fWj(InterfaceC15340gnp<? extends T> interfaceC15340gnp) {
|
|
this.e = interfaceC15340gnp;
|
|
}
|
|
|
|
@Override // o.AbstractC13163fSk
|
|
public final void subscribeActual(InterfaceC13174fSv<? super T> interfaceC13174fSv) {
|
|
this.e.a(new HBt(interfaceC13174fSv));
|
|
}
|
|
|
|
/* renamed from: o.fWj$HBt */
|
|
/* loaded from: classes6.dex */
|
|
static final class HBt<T> implements InterfaceC13158fSf<T>, fSJ {
|
|
private InterfaceC13174fSv<? super T> d;
|
|
private InterfaceC15337gnm e;
|
|
|
|
HBt(InterfaceC13174fSv<? super T> interfaceC13174fSv) {
|
|
this.d = interfaceC13174fSv;
|
|
}
|
|
|
|
@Override // o.InterfaceC15338gnn
|
|
public final void onComplete() {
|
|
this.d.onComplete();
|
|
}
|
|
|
|
@Override // o.InterfaceC15338gnn
|
|
public final void onError(Throwable th) {
|
|
this.d.onError(th);
|
|
}
|
|
|
|
@Override // o.InterfaceC15338gnn
|
|
public final void onNext(T t) {
|
|
this.d.onNext(t);
|
|
}
|
|
|
|
@Override // o.InterfaceC13158fSf, o.InterfaceC15338gnn
|
|
public final void c(InterfaceC15337gnm interfaceC15337gnm) {
|
|
if (fYC.e(this.e, interfaceC15337gnm)) {
|
|
this.e = interfaceC15337gnm;
|
|
this.d.onSubscribe(this);
|
|
interfaceC15337gnm.c(Long.MAX_VALUE);
|
|
}
|
|
}
|
|
|
|
@Override // o.fSJ
|
|
public final void dispose() {
|
|
this.e.a();
|
|
this.e = fYC.CANCELLED;
|
|
}
|
|
|
|
@Override // o.fSJ
|
|
public final boolean isDisposed() {
|
|
return this.e == fYC.CANCELLED;
|
|
}
|
|
}
|
|
}
|