package defpackage;

import androidx.media3.container.NalUnitUtil;
import defpackage.fx4;
import java.util.concurrent.CancellationException;
import kotlin.Metadata;

/* JADX INFO: loaded from: classes3.dex */
@Metadata(d1 = {"lx4", "nx4"}, d2 = {}, k = 4, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
public final class kx4 {
    public static hx4 a() {
        return new hx4(null);
    }

    public static final void b(gj1 gj1Var, CancellationException cancellationException) {
        fx4 fx4Var = (fx4) gj1Var.cb(fx4.b.a);
        if (fx4Var != null) {
            fx4Var.h(cancellationException);
        }
    }

    public static final void c(gj1 gj1Var) {
        fx4 fx4Var = (fx4) gj1Var.cb(fx4.b.a);
        if (fx4Var != null && !fx4Var.isActive()) {
            throw fx4Var.w();
        }
    }

    public static final fx4 d(gj1 gj1Var) {
        fx4 fx4Var = (fx4) gj1Var.cb(fx4.b.a);
        if (fx4Var != null) {
            return fx4Var;
        }
        throw new IllegalStateException(("Current context doesn't contain Job in it: " + gj1Var).toString());
    }

    public static final ld2 e(fx4 fx4Var, boolean z, qx4 qx4Var) {
        return fx4Var instanceof rx4 ? ((rx4) fx4Var).bh(z, qx4Var) : fx4Var.bc(qx4Var.k(), z, new mx4(1, qx4Var, qx4.class, "invoke", "invoke(Ljava/lang/Throwable;)V", 0));
    }
}