package c.a.q.e.b;

import c.a.g;
import c.a.h;
import c.a.j;
import c.a.l;
import java.util.concurrent.atomic.AtomicReference;

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

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

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    final g f1797b;

    /* JADX INFO: compiled from: SingleObserveOn.java */
    static final class a<T> extends AtomicReference<c.a.n.b> implements j<T>, c.a.n.b, Runnable {

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

        /* JADX INFO: renamed from: d, reason: collision with root package name */
        final g f1799d;

        /* JADX INFO: renamed from: e, reason: collision with root package name */
        T f1800e;

        /* JADX INFO: renamed from: f, reason: collision with root package name */
        Throwable f1801f;

        a(j<? super T> jVar, g gVar) {
            this.f1798c = jVar;
            this.f1799d = gVar;
        }

        @Override // c.a.j, c.a.a, c.a.c
        public void a(c.a.n.b bVar) {
            if (c.a.q.a.b.setOnce(this, bVar)) {
                this.f1798c.a(this);
            }
        }

        @Override // c.a.j, c.a.a, c.a.c
        public void b(Throwable th) {
            this.f1801f = th;
            c.a.q.a.b.replace(this, this.f1799d.b(this));
        }

        @Override // c.a.j
        public void d(T t) {
            this.f1800e = t;
            c.a.q.a.b.replace(this, this.f1799d.b(this));
        }

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

        @Override // java.lang.Runnable
        public void run() {
            Throwable th = this.f1801f;
            if (th != null) {
                this.f1798c.b(th);
            } else {
                this.f1798c.d(this.f1800e);
            }
        }
    }

    public e(l<T> lVar, g gVar) {
        this.f1796a = lVar;
        this.f1797b = gVar;
    }

    @Override // c.a.h
    protected void k(j<? super T> jVar) {
        this.f1796a.a(new a(jVar, this.f1797b));
    }
}