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 f5706c;

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

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

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

    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> f5710b;

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

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

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

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

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

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

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

        public final class b implements Runnable {

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

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

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

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

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

            public RunnableC0079c(T t) {
                this.f5719b = t;
            }

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

        public a(d.a.l<? super T> lVar, long j2, TimeUnit timeUnit, m.c cVar, boolean z) {
            this.f5710b = lVar;
            this.f5711c = j2;
            this.f5712d = timeUnit;
            this.f5713e = cVar;
            this.f5714f = z;
        }

        @Override // d.a.l
        public void a(Throwable th) {
            this.f5713e.c(new b(th), this.f5714f ? this.f5711c : 0L, this.f5712d);
        }

        @Override // d.a.l
        public void b() {
            this.f5713e.c(new RunnableC0078a(), this.f5711c, this.f5712d);
        }

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

        @Override // d.a.l
        public void d(T t) {
            this.f5713e.c(new RunnableC0079c(t), this.f5711c, this.f5712d);
        }

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

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

    public c(d.a.k<T> kVar, long j2, TimeUnit timeUnit, d.a.m mVar, boolean z) {
        super(kVar);
        this.f5706c = j2;
        this.f5707d = timeUnit;
        this.f5708e = mVar;
        this.f5709f = z;
    }

    @Override // d.a.h
    public void o(d.a.l<? super T> lVar) {
        this.f5703b.e(new a(this.f5709f ? lVar : new d.a.t.a(lVar), this.f5706c, this.f5707d, this.f5708e.a(), this.f5709f));
    }
}