package e.a.u.d;

import e.a.m;

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

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    protected final m<? super R> f3645b;

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    protected e.a.r.b f3646f;

    /* JADX INFO: renamed from: g, reason: collision with root package name */
    protected e.a.u.c.a<T> f3647g;

    /* JADX INFO: renamed from: h, reason: collision with root package name */
    protected boolean f3648h;

    /* JADX INFO: renamed from: i, reason: collision with root package name */
    protected int f3649i;

    public a(m<? super R> mVar) {
        this.f3645b = mVar;
    }

    @Override // e.a.m
    public void a() {
        if (this.f3648h) {
            return;
        }
        this.f3648h = true;
        this.f3645b.a();
    }

    @Override // e.a.m
    public void b(Throwable th) {
        if (this.f3648h) {
            e.a.w.a.p(th);
        } else {
            this.f3648h = true;
            this.f3645b.b(th);
        }
    }

    @Override // e.a.m
    public final void c(e.a.r.b bVar) {
        if (e.a.u.a.b.validate(this.f3646f, bVar)) {
            this.f3646f = bVar;
            if (bVar instanceof e.a.u.c.a) {
                this.f3647g = (e.a.u.c.a) bVar;
            }
            if (f()) {
                this.f3645b.c(this);
                e();
            }
        }
    }

    @Override // e.a.u.c.e
    public void clear() {
        this.f3647g.clear();
    }

    @Override // e.a.r.b
    public void dispose() {
        this.f3646f.dispose();
    }

    protected void e() {
    }

    protected boolean f() {
        return true;
    }

    protected final void g(Throwable th) {
        e.a.s.b.b(th);
        this.f3646f.dispose();
        b(th);
    }

    protected final int h(int i2) {
        e.a.u.c.a<T> aVar = this.f3647g;
        if (aVar == null || (i2 & 4) != 0) {
            return 0;
        }
        int iRequestFusion = aVar.requestFusion(i2);
        if (iRequestFusion != 0) {
            this.f3649i = iRequestFusion;
        }
        return iRequestFusion;
    }

    @Override // e.a.r.b
    public boolean isDisposed() {
        return this.f3646f.isDisposed();
    }

    @Override // e.a.u.c.e
    public boolean isEmpty() {
        return this.f3647g.isEmpty();
    }

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