package f.a.w.d;

import f.a.n;

/* JADX INFO: compiled from: BasicFuseableObserver.java */
/* JADX INFO: loaded from: classes.dex */
public abstract class a<T, R> implements n<T>, f.a.w.c.a<R> {

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final n<? super R> f3731b;

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    public f.a.t.b f3732e;

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    public f.a.w.c.a<T> f3733f;

    /* JADX INFO: renamed from: g, reason: collision with root package name */
    public boolean f3734g;

    /* JADX INFO: renamed from: h, reason: collision with root package name */
    public int f3735h;

    public a(n<? super R> nVar) {
        this.f3731b = nVar;
    }

    @Override // f.a.n
    public void a(Throwable th) {
        if (this.f3734g) {
            f.a.y.a.C0(th);
        } else {
            this.f3734g = true;
            this.f3731b.a(th);
        }
    }

    @Override // f.a.n
    public final void b(f.a.t.b bVar) {
        if (f.a.w.a.b.validate(this.f3732e, bVar)) {
            this.f3732e = bVar;
            if (bVar instanceof f.a.w.c.a) {
                this.f3733f = (f.a.w.c.a) bVar;
            }
            this.f3731b.b(this);
        }
    }

    @Override // f.a.w.c.d
    public void clear() {
        this.f3733f.clear();
    }

    public final void d(Throwable th) {
        d.i.c.a.L(th);
        this.f3732e.dispose();
        a(th);
    }

    @Override // f.a.t.b
    public void dispose() {
        this.f3732e.dispose();
    }

    public final int e(int i2) {
        f.a.w.c.a<T> aVar = this.f3733f;
        if (aVar == null || (i2 & 4) != 0) {
            return 0;
        }
        int iRequestFusion = aVar.requestFusion(i2);
        if (iRequestFusion != 0) {
            this.f3735h = iRequestFusion;
        }
        return iRequestFusion;
    }

    @Override // f.a.w.c.d
    public boolean isEmpty() {
        return this.f3733f.isEmpty();
    }

    @Override // f.a.w.c.d
    public final boolean offer(R r) {
        throw new UnsupportedOperationException("Should not be called!");
    }

    @Override // f.a.n
    public void onComplete() {
        if (this.f3734g) {
            return;
        }
        this.f3734g = true;
        this.f3731b.onComplete();
    }
}