package d.a.s.e.c;

import d.a.m;
import java.util.concurrent.TimeUnit;

/* JADX INFO: loaded from: classes.dex */
public final class c<T> extends d.a.s.e.c.a<T, T> {

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public final long f5691c;

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    public final TimeUnit f5692d;

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    public final d.a.m f5693e;

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    public final boolean f5694f;

    public static final class a<T> implements d.a.l<T>, d.a.p.b {

        /* JADX INFO: renamed from: b, reason: collision with root package name */
        public final d.a.l<? super T> f5695b;

        /* JADX INFO: renamed from: c, reason: collision with root package name */
        public final long f5696c;

        /* JADX INFO: renamed from: d, reason: collision with root package name */
        public final TimeUnit f5697d;

        /* JADX INFO: renamed from: e, reason: collision with root package name */
        public final m.c f5698e;

        /* JADX INFO: renamed from: f, reason: collision with root package name */
        public final boolean f5699f;

        /* JADX INFO: renamed from: g, reason: collision with root package name */
        public d.a.p.b f5700g;

        /* JADX INFO: renamed from: d.a.s.e.c.c$a$a, reason: collision with other inner class name */
        public final class RunnableC0080a implements Runnable {
            public RunnableC0080a() {
            }

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

        public final class b implements Runnable {

            /* JADX INFO: renamed from: b, reason: collision with root package name */
            public final Throwable f5702b;

            public b(Throwable th) {
                this.f5702b = th;
            }

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

        /* JADX INFO: renamed from: d.a.s.e.c.c$a$c, reason: collision with other inner class name */
        public final class RunnableC0081c implements Runnable {

            /* JADX INFO: renamed from: b, reason: collision with root package name */
            public final T f5704b;

            public RunnableC0081c(T t) {
                this.f5704b = t;
            }

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

        public a(d.a.l<? super T> lVar, long j2, TimeUnit timeUnit, m.c cVar, boolean z) {
            this.f5695b = lVar;
            this.f5696c = j2;
            this.f5697d = timeUnit;
            this.f5698e = cVar;
            this.f5699f = z;
        }

        @Override // d.a.l
        public void a(Throwable th) {
            this.f5698e.c(new b(th), this.f5699f ? this.f5696c : 0L, this.f5697d);
        }

        @Override // d.a.l
        public void b() {
            this.f5698e.c(new RunnableC0080a(), this.f5696c, this.f5697d);
        }

        @Override // d.a.l
        public void c(d.a.p.b bVar) {
            if (d.a.s.a.b.validate(this.f5700g, bVar)) {
                this.f5700g = bVar;
                this.f5695b.c(this);
            }
        }

        @Override // d.a.l
        public void d(T t) {
            this.f5698e.c(new RunnableC0081c(t), this.f5696c, this.f5697d);
        }

        @Override // d.a.p.b
        public void dispose() {
            this.f5700g.dispose();
            this.f5698e.dispose();
        }

        @Override // d.a.p.b
        public boolean isDisposed() {
            return this.f5698e.isDisposed();
        }
    }

    public c(d.a.k<T> kVar, long j2, TimeUnit timeUnit, d.a.m mVar, boolean z) {
        super(kVar);
        this.f5691c = j2;
        this.f5692d = timeUnit;
        this.f5693e = mVar;
        this.f5694f = z;
    }

    @Override // d.a.h
    public void o(d.a.l<? super T> lVar) {
        this.f5688b.e(new a(this.f5694f ? lVar : new d.a.t.a(lVar), this.f5691c, this.f5692d, this.f5693e.a(), this.f5694f));
    }
}