package i.a.n.d;

import i.a.g;

/* JADX INFO: compiled from: DisposableLambdaObserver.java */
/* JADX INFO: loaded from: classes.dex */
public final class c<T> implements g<T>, i.a.k.b {
    final g<? super T> b;
    final i.a.m.c<? super i.a.k.b> d;
    final i.a.m.a e;
    i.a.k.b f;

    public c(g<? super T> gVar, i.a.m.c<? super i.a.k.b> cVar, i.a.m.a aVar) {
        this.b = gVar;
        this.d = cVar;
        this.e = aVar;
    }

    @Override // i.a.g
    public void a(Throwable th) {
        if (this.f != i.a.n.a.b.DISPOSED) {
            this.b.a(th);
        } else {
            i.a.p.a.l(th);
        }
    }

    @Override // i.a.g
    public void b() {
        if (this.f != i.a.n.a.b.DISPOSED) {
            this.b.b();
        }
    }

    @Override // i.a.g
    public void c(i.a.k.b bVar) {
        try {
            this.d.accept(bVar);
            if (i.a.n.a.b.validate(this.f, bVar)) {
                this.f = bVar;
                this.b.c(this);
            }
        } catch (Throwable th) {
            i.a.l.b.b(th);
            bVar.dispose();
            this.f = i.a.n.a.b.DISPOSED;
            i.a.n.a.c.error(th, this.b);
        }
    }

    @Override // i.a.g
    public void d(T t) {
        this.b.d(t);
    }

    @Override // i.a.k.b
    public void dispose() {
        try {
            this.e.run();
        } catch (Throwable th) {
            i.a.l.b.b(th);
            i.a.p.a.l(th);
        }
        this.f.dispose();
    }

    @Override // i.a.k.b
    public boolean isDisposed() {
        return this.f.isDisposed();
    }
}