package defpackage;

import androidx.media3.container.NalUnitUtil;
import defpackage.r77;
import kotlin.Metadata;
import kotlin.coroutines.Continuation;
import kotlin.coroutines.jvm.internal.SuspendLambda;

/* JADX INFO: loaded from: classes3.dex */
@Metadata(d1 = {"\u0000\u001e\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0010\u0003\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0000\bÀ\u0002\u0018\u00002,\u0012(\u0012&\b\u0001\u0012\u0004\u0012\u00020\u0003\u0012\u0004\u0012\u00020\u0004\u0012\f\u0012\n\u0012\u0006\u0012\u0004\u0018\u00010\u00040\u0005\u0012\u0006\u0012\u0004\u0018\u00010\u00060\u00020\u0001¨\u0006\u0007"}, d2 = {"Lev7;", "Lf11;", "Lkotlin/Function3;", "Led4;", "", "Lkotlin/coroutines/Continuation;", "", "ktor-client-core"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
public final class ev7 implements f11<ir3<? super ed4, ? super Throwable, ? super Continuation<? super Throwable>, ? extends Object>> {
    public static final ev7 a = new ev7();

    /* JADX WARN: Multi-variable type inference failed */
    @Override // defpackage.f11
    public final void a(ta4 ta4Var, SuspendLambda suspendLambda) throws vr4 {
        ir3 ir3Var = (ir3) suspendLambda;
        cr4.g(ta4Var, "client");
        q77 q77Var = new q77("BeforeReceive");
        zd4 zd4Var = ta4Var.f;
        zd4Var.getClass();
        q77 q77Var2 = zd4.g;
        cr4.g(q77Var2, "reference");
        if (!zd4Var.e(q77Var)) {
            int iC = zd4Var.c(q77Var2);
            if (iC == -1) {
                throw new vr4("Phase " + q77Var2 + " was not registered for this pipeline");
            }
            zd4Var.b.add(iC, new m67(q77Var, new r77.b()));
        }
        zd4Var.g(q77Var, new dv7(ir3Var, null));
    }
}