package c.a.q.e.b;

import c.a.h;
import c.a.i;
import c.a.j;
import c.a.k;
import java.util.concurrent.atomic.AtomicReference;

/* JADX INFO: compiled from: SingleCreate.java */
/* JADX INFO: loaded from: classes.dex */
public final class a<T> extends h<T> {

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    final k<T> f1778a;

    /* JADX INFO: renamed from: c.a.q.e.b.a$a, reason: collision with other inner class name */
    /* JADX INFO: compiled from: SingleCreate.java */
    static final class C0067a<T> extends AtomicReference<c.a.n.b> implements i<T>, c.a.n.b {

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

        C0067a(j<? super T> jVar) {
            this.f1779c = jVar;
        }

        public void a(Throwable th) {
            if (b(th)) {
                return;
            }
            c.a.r.a.o(th);
        }

        public boolean b(Throwable th) {
            c.a.n.b andSet;
            if (th == null) {
                th = new NullPointerException("onError called with null. Null values are generally not allowed in 2.x operators and sources.");
            }
            c.a.n.b bVar = get();
            c.a.q.a.b bVar2 = c.a.q.a.b.DISPOSED;
            if (bVar == bVar2 || (andSet = getAndSet(bVar2)) == bVar2) {
                return false;
            }
            try {
                this.f1779c.b(th);
            } finally {
                if (andSet != null) {
                    andSet.dispose();
                }
            }
        }

        @Override // c.a.i
        public void d(T t) {
            c.a.n.b andSet;
            c.a.n.b bVar = get();
            c.a.q.a.b bVar2 = c.a.q.a.b.DISPOSED;
            if (bVar == bVar2 || (andSet = getAndSet(bVar2)) == bVar2) {
                return;
            }
            try {
                if (t == null) {
                    this.f1779c.b(new NullPointerException("onSuccess called with null. Null values are generally not allowed in 2.x operators and sources."));
                } else {
                    this.f1779c.d(t);
                }
                if (andSet != null) {
                    andSet.dispose();
                }
            } catch (Throwable th) {
                if (andSet != null) {
                    andSet.dispose();
                }
                throw th;
            }
        }

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

    public a(k<T> kVar) {
        this.f1778a = kVar;
    }

    @Override // c.a.h
    protected void k(j<? super T> jVar) {
        C0067a c0067a = new C0067a(jVar);
        jVar.a(c0067a);
        try {
            this.f1778a.a(c0067a);
        } catch (Throwable th) {
            c.a.o.b.b(th);
            c0067a.a(th);
        }
    }
}