package defpackage;

import androidx.media3.container.NalUnitUtil;
import androidx.media3.exoplayer.upstream.CmcdData;
import java.util.ArrayList;
import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;
import java.util.concurrent.atomic.AtomicReferenceFieldUpdater;
import kotlin.Metadata;

/* JADX INFO: loaded from: classes3.dex */
@Metadata(d1 = {"\u0000\u0012\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u0000\n\u0002\u0018\u0002\n\u0002\b\u0004\b\u0002\u0018\u0000*\u0004\b\u0000\u0010\u00012\u00020\u0002:\u0002\u0005\u0006R\u000b\u0010\u0004\u001a\u00020\u00038\u0002X\u0082\u0004¨\u0006\u0007"}, d2 = {"Lf50;", "T", "", "Lnw;", "notCompletedCount", "b", CmcdData.OBJECT_TYPE_AUDIO_ONLY, "kotlinx-coroutines-core"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
@vx8
final class f50<T> {
    public static final /* synthetic */ AtomicIntegerFieldUpdater b = AtomicIntegerFieldUpdater.newUpdater(f50.class, "notCompletedCount$volatile");
    public final r22[] a;
    private volatile /* synthetic */ int notCompletedCount$volatile;

    @Metadata(d1 = {"\u0000\u0018\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\b\u0082\u0004\u0018\u00002\u00020\u0001R\u001d\u0010\u0005\u001a\u0014\u0012\u0010\u0012\u000e\u0018\u00010\u0003R\b\u0012\u0004\u0012\u00028\u00000\u00040\u00028\u0002X\u0082\u0004¨\u0006\u0006"}, d2 = {"Lf50$a;", "Lqx4;", "Lww;", "Lf50$b;", "Lf50;", "_disposer", "kotlinx-coroutines-core"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
    @vx8
    public final class a extends qx4 {
        public static final /* synthetic */ AtomicReferenceFieldUpdater j = AtomicReferenceFieldUpdater.newUpdater(a.class, Object.class, "_disposer$volatile");
        private volatile /* synthetic */ Object _disposer$volatile;
        public final ts0 e;
        public ld2 f;

        public a(ts0 ts0Var) {
            this.e = ts0Var;
        }

        @Override // defpackage.qx4
        public final boolean k() {
            return false;
        }

        @Override // defpackage.qx4
        public final void l(Throwable th) {
            ts0 ts0Var = this.e;
            if (th != null) {
                ts0Var.getClass();
                kg9 kg9VarAd = ts0Var.ad(new w81(th, false), null);
                if (kg9VarAd != null) {
                    ts0Var.v(kg9VarAd);
                    b bVar = (b) j.get(this);
                    if (bVar != null) {
                        bVar.a();
                        return;
                    }
                    return;
                }
                return;
            }
            AtomicIntegerFieldUpdater atomicIntegerFieldUpdater = f50.b;
            f50 f50Var = f50.this;
            if (atomicIntegerFieldUpdater.decrementAndGet(f50Var) == 0) {
                r22[] r22VarArr = f50Var.a;
                ArrayList arrayList = new ArrayList(r22VarArr.length);
                for (r22 r22Var : r22VarArr) {
                    arrayList.add(r22Var.n());
                }
                ts0Var.resumeWith(arrayList);
            }
        }
    }

    @Metadata(d1 = {"\u0000\n\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\b\u0082\u0004\u0018\u00002\u00020\u0001¨\u0006\u0002"}, d2 = {"Lf50$b;", "Lks0;", "kotlinx-coroutines-core"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
    @vx8
    public final class b implements ks0 {
        public final a[] a;

        public b(a[] aVarArr) {
            this.a = aVarArr;
        }

        public final void a() {
            for (a aVar : this.a) {
                ld2 ld2Var = aVar.f;
                if (ld2Var == null) {
                    cr4.n("handle");
                    throw null;
                }
                ld2Var.c();
            }
        }

        @Override // defpackage.ks0
        public final void b(Throwable th) {
            a();
        }

        public final String toString() {
            return "DisposeHandlersOnCancel[" + this.a + ']';
        }
    }

    public f50(r22[] r22VarArr) {
        this.a = r22VarArr;
        this.notCompletedCount$volatile = r22VarArr.length;
    }
}