package o.a.h.d;

import g.h.a.i;
import java.util.Objects;
import java.util.concurrent.atomic.AtomicReference;
import o.a.c;
import o.a.h.b.a;

/* JADX INFO: loaded from: classes.dex */
public final class b<T> extends AtomicReference<o.a.e.b> implements c<T>, o.a.e.b {

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    public final o.a.g.b<? super T> f5975f;

    /* JADX INFO: renamed from: m, reason: collision with root package name */
    public final o.a.g.b<? super Throwable> f5976m;

    /* JADX INFO: renamed from: n, reason: collision with root package name */
    public final o.a.g.a f5977n;

    /* JADX INFO: renamed from: o, reason: collision with root package name */
    public final o.a.g.b<? super o.a.e.b> f5978o;

    public b(o.a.g.b<? super T> bVar, o.a.g.b<? super Throwable> bVar2, o.a.g.a aVar, o.a.g.b<? super o.a.e.b> bVar3) {
        this.f5975f = bVar;
        this.f5976m = bVar2;
        this.f5977n = aVar;
        this.f5978o = bVar3;
    }

    @Override // o.a.c
    public void a(o.a.e.b bVar) {
        if (o.a.h.a.b.h(this, bVar)) {
            try {
                this.f5978o.accept(this);
            } catch (Throwable th) {
                i.F3(th);
                bVar.b();
                c(th);
            }
        }
    }

    @Override // o.a.e.b
    public void b() {
        o.a.h.a.b.g(this);
    }

    @Override // o.a.c
    public void c(Throwable th) {
        if (f()) {
            i.P2(th);
            return;
        }
        lazySet(o.a.h.a.b.DISPOSED);
        try {
            this.f5976m.accept(th);
        } catch (Throwable th2) {
            i.F3(th2);
            i.P2(new o.a.f.a(th, th2));
        }
    }

    @Override // o.a.c
    public void d(T t2) {
        if (f()) {
            return;
        }
        try {
            this.f5975f.accept(t2);
        } catch (Throwable th) {
            i.F3(th);
            get().b();
            c(th);
        }
    }

    public boolean f() {
        return get() == o.a.h.a.b.DISPOSED;
    }

    @Override // o.a.c
    public void onComplete() {
        if (f()) {
            return;
        }
        lazySet(o.a.h.a.b.DISPOSED);
        try {
            Objects.requireNonNull((a.C0096a) this.f5977n);
        } catch (Throwable th) {
            i.F3(th);
            i.P2(th);
        }
    }
}