package c.a.q.d;

import c.a.f;
import c.a.p.e;
import java.util.concurrent.atomic.AtomicReference;

/* JADX INFO: compiled from: LambdaObserver.java */
/* JADX INFO: loaded from: classes.dex */
public final class d<T> extends AtomicReference<c.a.n.b> implements f<T>, c.a.n.b {

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    final e<? super T> f1752c;

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    final e<? super Throwable> f1753d;

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    final c.a.p.a f1754e;

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    final e<? super c.a.n.b> f1755f;

    public d(e<? super T> eVar, e<? super Throwable> eVar2, c.a.p.a aVar, e<? super c.a.n.b> eVar3) {
        this.f1752c = eVar;
        this.f1753d = eVar2;
        this.f1754e = aVar;
        this.f1755f = eVar3;
    }

    @Override // c.a.f
    public void a(c.a.n.b bVar) {
        if (c.a.q.a.b.setOnce(this, bVar)) {
            try {
                this.f1755f.accept(this);
            } catch (Throwable th) {
                c.a.o.b.b(th);
                bVar.dispose();
                b(th);
            }
        }
    }

    @Override // c.a.f
    public void b(Throwable th) {
        if (e()) {
            return;
        }
        lazySet(c.a.q.a.b.DISPOSED);
        try {
            this.f1753d.accept(th);
        } catch (Throwable th2) {
            c.a.o.b.b(th2);
            c.a.r.a.o(new c.a.o.a(th, th2));
        }
    }

    @Override // c.a.f
    public void c() {
        if (e()) {
            return;
        }
        lazySet(c.a.q.a.b.DISPOSED);
        try {
            this.f1754e.run();
        } catch (Throwable th) {
            c.a.o.b.b(th);
            c.a.r.a.o(th);
        }
    }

    @Override // c.a.f
    public void d(T t) {
        if (e()) {
            return;
        }
        try {
            this.f1752c.accept(t);
        } catch (Throwable th) {
            c.a.o.b.b(th);
            get().dispose();
            b(th);
        }
    }

    @Override // c.a.n.b
    public void dispose() {
        c.a.q.a.b.dispose(this);
    }

    public boolean e() {
        return get() == c.a.q.a.b.DISPOSED;
    }
}