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.TimeUnit;
import java.util.concurrent.TimeoutException;
import java.util.concurrent.atomic.AtomicBoolean;

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

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

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

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    final TimeUnit f1804c;

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

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    final l<? extends T> f1806e;

    /* JADX INFO: compiled from: SingleTimeout.java */
    final class a implements Runnable {

        /* JADX INFO: renamed from: c, reason: collision with root package name */
        private final AtomicBoolean f1807c;

        /* JADX INFO: renamed from: d, reason: collision with root package name */
        final c.a.n.a f1808d;

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

        /* JADX INFO: renamed from: c.a.q.e.b.f$a$a, reason: collision with other inner class name */
        /* JADX INFO: compiled from: SingleTimeout.java */
        final class C0070a implements j<T> {
            C0070a() {
            }

            @Override // c.a.j, c.a.a, c.a.c
            public void a(c.a.n.b bVar) {
                a.this.f1808d.b(bVar);
            }

            @Override // c.a.j, c.a.a, c.a.c
            public void b(Throwable th) {
                a.this.f1808d.dispose();
                a.this.f1809e.b(th);
            }

            @Override // c.a.j
            public void d(T t) {
                a.this.f1808d.dispose();
                a.this.f1809e.d(t);
            }
        }

        a(AtomicBoolean atomicBoolean, c.a.n.a aVar, j<? super T> jVar) {
            this.f1807c = atomicBoolean;
            this.f1808d = aVar;
            this.f1809e = jVar;
        }

        @Override // java.lang.Runnable
        public void run() {
            if (this.f1807c.compareAndSet(false, true)) {
                if (f.this.f1806e != null) {
                    this.f1808d.d();
                    f.this.f1806e.a(new C0070a());
                } else {
                    this.f1808d.dispose();
                    this.f1809e.b(new TimeoutException());
                }
            }
        }
    }

    /* JADX INFO: compiled from: SingleTimeout.java */
    final class b implements j<T> {

        /* JADX INFO: renamed from: c, reason: collision with root package name */
        private final AtomicBoolean f1812c;

        /* JADX INFO: renamed from: d, reason: collision with root package name */
        private final c.a.n.a f1813d;

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

        b(AtomicBoolean atomicBoolean, c.a.n.a aVar, j<? super T> jVar) {
            this.f1812c = atomicBoolean;
            this.f1813d = aVar;
            this.f1814e = jVar;
        }

        @Override // c.a.j, c.a.a, c.a.c
        public void a(c.a.n.b bVar) {
            this.f1813d.b(bVar);
        }

        @Override // c.a.j, c.a.a, c.a.c
        public void b(Throwable th) {
            if (this.f1812c.compareAndSet(false, true)) {
                this.f1813d.dispose();
                this.f1814e.b(th);
            }
        }

        @Override // c.a.j
        public void d(T t) {
            if (this.f1812c.compareAndSet(false, true)) {
                this.f1813d.dispose();
                this.f1814e.d(t);
            }
        }
    }

    public f(l<T> lVar, long j, TimeUnit timeUnit, g gVar, l<? extends T> lVar2) {
        this.f1802a = lVar;
        this.f1803b = j;
        this.f1804c = timeUnit;
        this.f1805d = gVar;
        this.f1806e = lVar2;
    }

    @Override // c.a.h
    protected void k(j<? super T> jVar) {
        c.a.n.a aVar = new c.a.n.a();
        jVar.a(aVar);
        AtomicBoolean atomicBoolean = new AtomicBoolean();
        aVar.b(this.f1805d.c(new a(atomicBoolean, aVar, jVar), this.f1803b, this.f1804c));
        this.f1802a.a(new b(atomicBoolean, aVar, jVar));
    }
}