package o;

/* renamed from: o.fWp, reason: case insensitive filesystem */
/* loaded from: classes.dex */
public final class C13307fWp<T> extends fRY implements InterfaceC13204fTr<T> {
    private InterfaceC13169fSq<T> e;

    public C13307fWp(InterfaceC13169fSq<T> interfaceC13169fSq) {
        this.e = interfaceC13169fSq;
    }

    @Override // o.fRY
    public final void c(InterfaceC13154fSb interfaceC13154fSb) {
        this.e.subscribe(new LWm(interfaceC13154fSb));
    }

    @Override // o.InterfaceC13204fTr
    public final AbstractC13163fSk<T> b() {
        return new C13305fWn(this.e);
    }

    /* renamed from: o.fWp$LWm */
    /* loaded from: classes6.dex */
    static final class LWm<T> implements InterfaceC13174fSv<T>, fSJ {
        private fSJ a;
        private InterfaceC13154fSb b;

        @Override // o.InterfaceC13174fSv
        public final void onNext(T t) {
        }

        LWm(InterfaceC13154fSb interfaceC13154fSb) {
            this.b = interfaceC13154fSb;
        }

        @Override // o.InterfaceC13174fSv
        public final void onSubscribe(fSJ fsj) {
            this.a = fsj;
            this.b.onSubscribe(this);
        }

        @Override // o.InterfaceC13174fSv
        public final void onError(Throwable th) {
            this.b.onError(th);
        }

        @Override // o.InterfaceC13174fSv
        public final void onComplete() {
            this.b.onComplete();
        }

        @Override // o.fSJ
        public final void dispose() {
            this.a.dispose();
        }

        @Override // o.fSJ
        public final boolean isDisposed() {
            return this.a.isDisposed();
        }
    }
}