package d.a.s.e.c;

import d.a.m;
import java.util.Objects;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;
import java.util.concurrent.atomic.AtomicLong;
import java.util.concurrent.atomic.AtomicReference;

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

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

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

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

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    public final d.a.k<? extends T> f5792f;

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

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

        /* JADX INFO: renamed from: c, reason: collision with root package name */
        public final AtomicReference<d.a.p.b> f5794c;

        public a(d.a.l<? super T> lVar, AtomicReference<d.a.p.b> atomicReference) {
            this.f5793b = lVar;
            this.f5794c = atomicReference;
        }

        @Override // d.a.l
        public void a(Throwable th) {
            this.f5793b.a(th);
        }

        @Override // d.a.l
        public void b() {
            this.f5793b.b();
        }

        @Override // d.a.l
        public void c(d.a.p.b bVar) {
            d.a.s.a.b.replace(this.f5794c, bVar);
        }

        @Override // d.a.l
        public void d(T t) {
            this.f5793b.d(t);
        }
    }

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

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

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

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

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

        /* JADX INFO: renamed from: f, reason: collision with root package name */
        public final d.a.s.a.e f5799f = new d.a.s.a.e();

        /* JADX INFO: renamed from: g, reason: collision with root package name */
        public final AtomicLong f5800g = new AtomicLong();

        /* JADX INFO: renamed from: h, reason: collision with root package name */
        public final AtomicReference<d.a.p.b> f5801h = new AtomicReference<>();

        /* JADX INFO: renamed from: i, reason: collision with root package name */
        public d.a.k<? extends T> f5802i;

        public b(d.a.l<? super T> lVar, long j2, TimeUnit timeUnit, m.c cVar, d.a.k<? extends T> kVar) {
            this.f5795b = lVar;
            this.f5796c = j2;
            this.f5797d = timeUnit;
            this.f5798e = cVar;
            this.f5802i = kVar;
        }

        @Override // d.a.l
        public void a(Throwable th) {
            if (this.f5800g.getAndSet(Long.MAX_VALUE) == Long.MAX_VALUE) {
                d.a.u.a.w(th);
                return;
            }
            d.a.s.a.e eVar = this.f5799f;
            Objects.requireNonNull(eVar);
            d.a.s.a.b.dispose(eVar);
            this.f5795b.a(th);
            this.f5798e.dispose();
        }

        @Override // d.a.l
        public void b() {
            if (this.f5800g.getAndSet(Long.MAX_VALUE) != Long.MAX_VALUE) {
                d.a.s.a.e eVar = this.f5799f;
                Objects.requireNonNull(eVar);
                d.a.s.a.b.dispose(eVar);
                this.f5795b.b();
                this.f5798e.dispose();
            }
        }

        @Override // d.a.l
        public void c(d.a.p.b bVar) {
            d.a.s.a.b.setOnce(this.f5801h, bVar);
        }

        @Override // d.a.l
        public void d(T t) {
            long j2 = this.f5800g.get();
            if (j2 != Long.MAX_VALUE) {
                long j3 = 1 + j2;
                if (this.f5800g.compareAndSet(j2, j3)) {
                    this.f5799f.get().dispose();
                    this.f5795b.d(t);
                    f(j3);
                }
            }
        }

        @Override // d.a.p.b
        public void dispose() {
            d.a.s.a.b.dispose(this.f5801h);
            d.a.s.a.b.dispose(this);
            this.f5798e.dispose();
        }

        @Override // d.a.s.e.c.q.d
        public void e(long j2) {
            if (this.f5800g.compareAndSet(j2, Long.MAX_VALUE)) {
                d.a.s.a.b.dispose(this.f5801h);
                d.a.k<? extends T> kVar = this.f5802i;
                this.f5802i = null;
                kVar.e(new a(this.f5795b, this));
                this.f5798e.dispose();
            }
        }

        public void f(long j2) {
            d.a.s.a.e eVar = this.f5799f;
            d.a.p.b bVarC = this.f5798e.c(new e(j2, this), this.f5796c, this.f5797d);
            Objects.requireNonNull(eVar);
            d.a.s.a.b.replace(eVar, bVarC);
        }

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

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

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

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

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

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

        /* JADX INFO: renamed from: f, reason: collision with root package name */
        public final d.a.s.a.e f5807f = new d.a.s.a.e();

        /* JADX INFO: renamed from: g, reason: collision with root package name */
        public final AtomicReference<d.a.p.b> f5808g = new AtomicReference<>();

        public c(d.a.l<? super T> lVar, long j2, TimeUnit timeUnit, m.c cVar) {
            this.f5803b = lVar;
            this.f5804c = j2;
            this.f5805d = timeUnit;
            this.f5806e = cVar;
        }

        @Override // d.a.l
        public void a(Throwable th) {
            if (getAndSet(Long.MAX_VALUE) == Long.MAX_VALUE) {
                d.a.u.a.w(th);
                return;
            }
            d.a.s.a.e eVar = this.f5807f;
            Objects.requireNonNull(eVar);
            d.a.s.a.b.dispose(eVar);
            this.f5803b.a(th);
            this.f5806e.dispose();
        }

        @Override // d.a.l
        public void b() {
            if (getAndSet(Long.MAX_VALUE) != Long.MAX_VALUE) {
                d.a.s.a.e eVar = this.f5807f;
                Objects.requireNonNull(eVar);
                d.a.s.a.b.dispose(eVar);
                this.f5803b.b();
                this.f5806e.dispose();
            }
        }

        @Override // d.a.l
        public void c(d.a.p.b bVar) {
            d.a.s.a.b.setOnce(this.f5808g, bVar);
        }

        @Override // d.a.l
        public void d(T t) {
            long j2 = get();
            if (j2 != Long.MAX_VALUE) {
                long j3 = 1 + j2;
                if (compareAndSet(j2, j3)) {
                    this.f5807f.get().dispose();
                    this.f5803b.d(t);
                    f(j3);
                }
            }
        }

        @Override // d.a.p.b
        public void dispose() {
            d.a.s.a.b.dispose(this.f5808g);
            this.f5806e.dispose();
        }

        @Override // d.a.s.e.c.q.d
        public void e(long j2) {
            if (compareAndSet(j2, Long.MAX_VALUE)) {
                d.a.s.a.b.dispose(this.f5808g);
                d.a.l<? super T> lVar = this.f5803b;
                long j3 = this.f5804c;
                TimeUnit timeUnit = this.f5805d;
                Throwable th = d.a.s.h.d.f5913a;
                lVar.a(new TimeoutException("The source did not signal an event for " + j3 + " " + timeUnit.toString().toLowerCase() + " and has been terminated."));
                this.f5806e.dispose();
            }
        }

        public void f(long j2) {
            d.a.s.a.e eVar = this.f5807f;
            d.a.p.b bVarC = this.f5806e.c(new e(j2, this), this.f5804c, this.f5805d);
            Objects.requireNonNull(eVar);
            d.a.s.a.b.replace(eVar, bVarC);
        }

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

    public interface d {
        void e(long j2);
    }

    public static final class e implements Runnable {

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

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

        public e(long j2, d dVar) {
            this.f5810c = j2;
            this.f5809b = dVar;
        }

        @Override // java.lang.Runnable
        public void run() {
            this.f5809b.e(this.f5810c);
        }
    }

    public q(d.a.h<T> hVar, long j2, TimeUnit timeUnit, d.a.m mVar, d.a.k<? extends T> kVar) {
        super(hVar);
        this.f5789c = j2;
        this.f5790d = timeUnit;
        this.f5791e = mVar;
        this.f5792f = kVar;
    }

    /* JADX WARN: Type inference fix 'apply assigned field type' failed
    java.lang.UnsupportedOperationException: ArgType.getObject(), call class: class jadx.core.dex.instructions.args.ArgType$UnknownArg
    	at jadx.core.dex.instructions.args.ArgType.getObject(ArgType.java:593)
    	at jadx.core.dex.attributes.nodes.ClassTypeVarsAttr.getTypeVarsMapFor(ClassTypeVarsAttr.java:35)
    	at jadx.core.dex.nodes.utils.TypeUtils.replaceClassGenerics(TypeUtils.java:177)
    	at jadx.core.dex.visitors.typeinference.FixTypesVisitor.insertExplicitUseCast(FixTypesVisitor.java:397)
    	at jadx.core.dex.visitors.typeinference.FixTypesVisitor.tryFieldTypeWithNewCasts(FixTypesVisitor.java:359)
    	at jadx.core.dex.visitors.typeinference.FixTypesVisitor.applyFieldType(FixTypesVisitor.java:309)
    	at jadx.core.dex.visitors.typeinference.FixTypesVisitor.visit(FixTypesVisitor.java:94)
     */
    @Override // d.a.h
    public void o(d.a.l<? super T> lVar) {
        d.a.l<? super T> lVar2;
        if (this.f5792f == null) {
            c cVar = new c(lVar, this.f5789c, this.f5790d, this.f5791e.a());
            lVar.c(cVar);
            cVar.f(0L);
            lVar2 = cVar;
        } else {
            b bVar = new b(lVar, this.f5789c, this.f5790d, this.f5791e.a(), this.f5792f);
            lVar.c(bVar);
            bVar.f(0L);
            lVar2 = bVar;
        }
        this.f5703b.e(lVar2);
    }
}