package d.a.s.e.c;

import java.util.concurrent.atomic.AtomicReference;

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

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

    public static final class a<T> extends AtomicReference<d.a.p.b> 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> f5785b;

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

        public a(d.a.l<? super T> lVar) {
            this.f5785b = lVar;
        }

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

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

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

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

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

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

    public final class b implements Runnable {

        /* JADX INFO: renamed from: b, reason: collision with root package name */
        public final a<T> f5787b;

        public b(a<T> aVar) {
            this.f5787b = aVar;
        }

        @Override // java.lang.Runnable
        public void run() {
            p.this.f5703b.e(this.f5787b);
        }
    }

    public p(d.a.k<T> kVar, d.a.m mVar) {
        super(kVar);
        this.f5784c = mVar;
    }

    @Override // d.a.h
    public void o(d.a.l<? super T> lVar) {
        a aVar = new a(lVar);
        lVar.c(aVar);
        d.a.s.a.b.setOnce(aVar, this.f5784c.b(new b(aVar)));
    }
}