package i.a.n.e.a;

import i.a.h;
import java.util.concurrent.TimeUnit;

/* JADX INFO: compiled from: ObservableDelay.java */
/* JADX INFO: loaded from: classes.dex */
public final class b<T> extends i.a.n.e.a.a<T, T> {
    final long d;
    final TimeUnit e;
    final i.a.h f;

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

    /* JADX INFO: compiled from: ObservableDelay.java */
    static final class a<T> implements i.a.g<T>, i.a.k.b {
        final i.a.g<? super T> b;
        final long d;
        final TimeUnit e;
        final h.c f;

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

        /* JADX INFO: renamed from: h, reason: collision with root package name */
        i.a.k.b f836h;

        /* JADX INFO: renamed from: i.a.n.e.a.b$a$a, reason: collision with other inner class name */
        /* JADX INFO: compiled from: ObservableDelay.java */
        final class RunnableC0077a implements Runnable {
            RunnableC0077a() {
            }

            @Override // java.lang.Runnable
            public void run() {
                try {
                    a.this.b.b();
                } finally {
                    a.this.f.dispose();
                }
            }
        }

        /* JADX INFO: renamed from: i.a.n.e.a.b$a$b, reason: collision with other inner class name */
        /* JADX INFO: compiled from: ObservableDelay.java */
        final class RunnableC0078b implements Runnable {
            private final Throwable b;

            RunnableC0078b(Throwable th) {
                this.b = th;
            }

            @Override // java.lang.Runnable
            public void run() {
                try {
                    a.this.b.a(this.b);
                } finally {
                    a.this.f.dispose();
                }
            }
        }

        /* JADX INFO: compiled from: ObservableDelay.java */
        final class c implements Runnable {
            private final T b;

            c(T t) {
                this.b = t;
            }

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

        a(i.a.g<? super T> gVar, long j2, TimeUnit timeUnit, h.c cVar, boolean z) {
            this.b = gVar;
            this.d = j2;
            this.e = timeUnit;
            this.f = cVar;
            this.f835g = z;
        }

        @Override // i.a.g
        public void a(Throwable th) {
            this.f.c(new RunnableC0078b(th), this.f835g ? this.d : 0L, this.e);
        }

        @Override // i.a.g
        public void b() {
            this.f.c(new RunnableC0077a(), this.d, this.e);
        }

        @Override // i.a.g
        public void c(i.a.k.b bVar) {
            if (i.a.n.a.b.validate(this.f836h, bVar)) {
                this.f836h = bVar;
                this.b.c(this);
            }
        }

        @Override // i.a.g
        public void d(T t) {
            this.f.c(new c(t), this.d, this.e);
        }

        @Override // i.a.k.b
        public void dispose() {
            this.f836h.dispose();
            this.f.dispose();
        }

        @Override // i.a.k.b
        public boolean isDisposed() {
            return this.f.isDisposed();
        }
    }

    public b(i.a.e<T> eVar, long j2, TimeUnit timeUnit, i.a.h hVar, boolean z) {
        super(eVar);
        this.d = j2;
        this.e = timeUnit;
        this.f = hVar;
        this.f834g = z;
    }

    @Override // i.a.d
    public void B(i.a.g<? super T> gVar) {
        this.b.a(new a(this.f834g ? gVar : new i.a.o.a(gVar), this.d, this.e, this.f.a(), this.f834g));
    }
}