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

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

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

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

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

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

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

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

        @Override // d.a.p.b
        public void dispose() {
            d.a.s.a.b.dispose(this.f5771c);
            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> f5772b;

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

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

    public p(d.a.k<T> kVar, d.a.m mVar) {
        super(kVar);
        this.f5769c = 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.f5769c.b(new b(aVar)));
    }
}