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;

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

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

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

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

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

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

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

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

        /* JADX INFO: renamed from: c.a.q.e.b.b$a$a, reason: collision with other inner class name */
        /* JADX INFO: compiled from: SingleDelay.java */
        final class RunnableC0068a implements Runnable {

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

            RunnableC0068a(Throwable th) {
                this.f1787c = th;
            }

            @Override // java.lang.Runnable
            public void run() {
                a.this.f1785d.b(this.f1787c);
            }
        }

        /* JADX INFO: renamed from: c.a.q.e.b.b$a$b, reason: collision with other inner class name */
        /* JADX INFO: compiled from: SingleDelay.java */
        final class RunnableC0069b implements Runnable {

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

            RunnableC0069b(T t) {
                this.f1789c = t;
            }

            @Override // java.lang.Runnable
            public void run() {
                a.this.f1785d.d(this.f1789c);
            }
        }

        a(c.a.q.a.e eVar, j<? super T> jVar) {
            this.f1784c = eVar;
            this.f1785d = jVar;
        }

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

        @Override // c.a.j, c.a.a, c.a.c
        public void b(Throwable th) {
            this.f1784c.b(b.this.f1783d.c(new RunnableC0068a(th), 0L, b.this.f1782c));
        }

        @Override // c.a.j
        public void d(T t) {
            c.a.q.a.e eVar = this.f1784c;
            g gVar = b.this.f1783d;
            RunnableC0069b runnableC0069b = new RunnableC0069b(t);
            b bVar = b.this;
            eVar.b(gVar.c(runnableC0069b, bVar.f1781b, bVar.f1782c));
        }
    }

    public b(l<? extends T> lVar, long j, TimeUnit timeUnit, g gVar) {
        this.f1780a = lVar;
        this.f1781b = j;
        this.f1782c = timeUnit;
        this.f1783d = gVar;
    }

    @Override // c.a.h
    protected void k(j<? super T> jVar) {
        c.a.q.a.e eVar = new c.a.q.a.e();
        jVar.a(eVar);
        this.f1780a.a(new a(eVar, jVar));
    }
}