package defpackage;

import androidx.media3.container.NalUnitUtil;
import defpackage.fx4;
import defpackage.gj1;
import java.util.Set;
import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;
import kotlin.Metadata;
import kotlinx.coroutines.CoroutineExceptionHandler;

/* JADX INFO: loaded from: classes3.dex */
@Metadata(d1 = {"\u0000\n\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\b&\u0018\u00002\u00020\u0001¨\u0006\u0002"}, d2 = {"Lfb4;", "Lab4;", "ktor-client-core"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
public abstract class fb4 implements ab4 {
    public static final /* synthetic */ AtomicIntegerFieldUpdater d = AtomicIntegerFieldUpdater.newUpdater(fb4.class, "closed");
    public final String a;
    public final j65 b;
    public final j65 c;

    @kp6
    private volatile /* synthetic */ int closed = 0;

    public fb4(String str) {
        this.a = str;
        final int i = 0;
        this.b = v65.a(new qq3(this) { // from class: eb4
            public final /* synthetic */ fb4 b;

            {
                this.b = this;
            }

            @Override // defpackage.qq3
            public final Object invoke() {
                int i2 = i;
                fb4 fb4Var = this.b;
                switch (i2) {
                    case 0:
                        AtomicIntegerFieldUpdater atomicIntegerFieldUpdater = fb4.d;
                        fb4Var.f().getClass();
                        m12 m12Var = sc2.a;
                        return m02.c;
                    default:
                        AtomicIntegerFieldUpdater atomicIntegerFieldUpdater2 = fb4.d;
                        return gj1.b.a.c((rx4) zd9.a(null), new ok1(CoroutineExceptionHandler.b.a)).bx((lj1) fb4Var.b.getValue()).bx(new xj1(fb4Var.a.concat("-context")));
                }
            }
        });
        final int i2 = 1;
        this.c = v65.a(new qq3(this) { // from class: eb4
            public final /* synthetic */ fb4 b;

            {
                this.b = this;
            }

            @Override // defpackage.qq3
            public final Object invoke() {
                int i22 = i2;
                fb4 fb4Var = this.b;
                switch (i22) {
                    case 0:
                        AtomicIntegerFieldUpdater atomicIntegerFieldUpdater = fb4.d;
                        fb4Var.f().getClass();
                        m12 m12Var = sc2.a;
                        return m02.c;
                    default:
                        AtomicIntegerFieldUpdater atomicIntegerFieldUpdater2 = fb4.d;
                        return gj1.b.a.c((rx4) zd9.a(null), new ok1(CoroutineExceptionHandler.b.a)).bx((lj1) fb4Var.b.getValue()).bx(new xj1(fb4Var.a.concat("-context")));
                }
            }
        });
    }

    @Override // defpackage.ab4
    public final void al(ta4 ta4Var) {
        ta4Var.i.g(je4.j, new db4(ta4Var, this, null));
    }

    @Override // defpackage.ab4
    /* JADX INFO: renamed from: bj */
    public Set getF() {
        return pk2.a;
    }

    @Override // java.io.Closeable, java.lang.AutoCloseable
    public void close() {
        if (d.compareAndSet(this, 0, 1)) {
            gj1.b bVarCb = getB().cb(fx4.b.a);
            u81 u81Var = bVarCb instanceof u81 ? (u81) bVarCb : null;
            if (u81Var == null) {
                return;
            }
            u81Var.bw();
        }
    }

    @Override // defpackage.ak1
    /* JADX INFO: renamed from: k */
    public gj1 getB() {
        return (gj1) this.c.getValue();
    }
}