package Y4;

import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;
import w4.C3137A;

/* JADX INFO: renamed from: Y4.d, reason: case insensitive filesystem */
/* JADX INFO: loaded from: classes3.dex */
public final class C0838d extends Z4.g {

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    public static final /* synthetic */ AtomicIntegerFieldUpdater f8934f = AtomicIntegerFieldUpdater.newUpdater(C0838d.class, "consumed$volatile");
    private volatile /* synthetic */ int consumed$volatile;

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

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

    public /* synthetic */ C0838d(X4.e eVar, boolean z6) {
        this(eVar, z6, A4.k.f106a, -3, X4.a.f8640a);
    }

    @Override // Z4.g, Y4.InterfaceC0843i
    public final Object collect(InterfaceC0844j interfaceC0844j, A4.d dVar) throws Throwable {
        C3137A c3137a = C3137A.f25453a;
        if (this.f9173b == -3) {
            boolean z6 = this.f8936e;
            if (z6 && f8934f.getAndSet(this, 1) != 0) {
                throw new IllegalStateException("ReceiveChannel.consumeAsFlow can be collected just once");
            }
            Object objK = O.k(interfaceC0844j, this.f8935d, z6, dVar);
            if (objK == B4.a.f492a) {
                return objK;
            }
        } else {
            Object objCollect = super.collect(interfaceC0844j, dVar);
            if (objCollect == B4.a.f492a) {
                return objCollect;
            }
        }
        return c3137a;
    }

    @Override // Z4.g
    public final String d() {
        return "channel=" + this.f8935d;
    }

    @Override // Z4.g
    public final Object e(X4.t tVar, A4.d dVar) throws Throwable {
        Object objK = O.k(new Z4.A(tVar), this.f8935d, this.f8936e, dVar);
        return objK == B4.a.f492a ? objK : C3137A.f25453a;
    }

    @Override // Z4.g
    public final Z4.g f(A4.j jVar, int i6, X4.a aVar) {
        return new C0838d(this.f8935d, this.f8936e, jVar, i6, aVar);
    }

    @Override // Z4.g
    public final InterfaceC0843i g() {
        return new C0838d(this.f8935d, this.f8936e);
    }

    @Override // Z4.g
    public final X4.v h(V4.C c6) {
        if (!this.f8936e || f8934f.getAndSet(this, 1) == 0) {
            return this.f9173b == -3 ? this.f8935d : super.h(c6);
        }
        throw new IllegalStateException("ReceiveChannel.consumeAsFlow can be collected just once");
    }

    public C0838d(X4.e eVar, boolean z6, A4.j jVar, int i6, X4.a aVar) {
        super(jVar, i6, aVar);
        this.f8935d = eVar;
        this.f8936e = z6;
        this.consumed$volatile = 0;
    }
}