package o;

/* loaded from: classes.dex */
public abstract class wRi {
    private yRw a;
    public yRw f;
    public C13196fTj h = new C13196fTj();
    public AbstractC13163fSk i;

    /* loaded from: classes3.dex */
    public static class LWm<T> extends AbstractC13403fZf<T> {
        @Override // o.InterfaceC13174fSv
        public void onComplete() {
        }

        @Override // o.InterfaceC13174fSv
        public void onError(Throwable th) {
        }

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

    public wRi(yRw yrw, yRw yrw2) {
        this.f = yrw;
        this.a = yrw2;
    }

    public final void a(LWm lWm) {
        d(this.i, lWm);
    }

    /* JADX WARN: Multi-variable type inference failed */
    public final <T> void e(AbstractC13163fSk<T> abstractC13163fSk, fSQ<T> fsq) {
        d(abstractC13163fSk.subscribeOn(this.f.d).observeOn(this.a.d).subscribe(fsq));
    }

    /* JADX WARN: Multi-variable type inference failed */
    public final <T> void d(AbstractC13163fSk<T> abstractC13163fSk, fSQ<T> fsq, fSQ<Throwable> fsq2) {
        d(abstractC13163fSk.subscribeOn(this.f.d).observeOn(this.a.d).subscribe(fsq, fsq2));
    }

    /* JADX INFO: Access modifiers changed from: package-private */
    public final void d(fSJ fsj) {
        if (this.h.isDisposed()) {
            this.h = new C13196fTj();
        }
        if (fsj != null) {
            this.h.e(fsj);
        }
    }

    public <T> void d(AbstractC13163fSk<T> abstractC13163fSk, LWm<T> lWm) {
        abstractC13163fSk.subscribeOn(this.f.d).observeOn(this.a.d).doOnSubscribe(new fSQ(this) { // from class: o.Ubc
            private wRi a;

            @Override // o.fSQ
            public final void c(Object obj) {
                this.a.d((fSJ) obj);
            }

            {
                this.a = this;
            }
        }).safeSubscribe(lWm);
    }

    /* JADX INFO: Access modifiers changed from: protected */
    public final AbstractC13163fSk e(AbstractC13163fSk abstractC13163fSk) {
        this.i = abstractC13163fSk;
        return abstractC13163fSk;
    }
}