package defpackage;

import androidx.media3.container.NalUnitUtil;
import defpackage.yg1;
import kotlin.Metadata;
import kotlin.coroutines.Continuation;

/* JADX INFO: loaded from: classes3.dex */
@Metadata(d1 = {"\u0000\u000e\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0000\b \u0018\u0000*\u0004\b\u0000\u0010\u0001*\u0004\b\u0001\u0010\u00022\b\u0012\u0004\u0012\u00028\u00010\u0003¨\u0006\u0004"}, d2 = {"Ldv0;", "S", "T", "Lvu0;", "kotlinx-coroutines-core"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
public abstract class dv0<S, T> extends vu0<T> {
    public final j43 d;

    public dv0(j43 j43Var, gj1 gj1Var, int i, ug0 ug0Var) {
        super(gj1Var, i, ug0Var);
        this.d = j43Var;
    }

    /* JADX WARN: Removed duplicated region for block: B:24:0x006e  */
    @Override // defpackage.vu0, defpackage.j43
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final Object collect(l43 l43Var, Continuation continuation) {
        if (this.b == -3) {
            gj1 b = continuation.getB();
            Boolean bool = Boolean.FALSE;
            mb1 mb1Var = new mb1(5);
            gj1 gj1Var = this.a;
            gj1 gj1VarBx = !((Boolean) gj1Var.z(bool, mb1Var)).booleanValue() ? b.bx(gj1Var) : jj1.a(b, gj1Var, false);
            if (cr4.b(gj1VarBx, b)) {
                Object objG = g(l43Var, continuation);
                if (objG == ck1.a) {
                    return objG;
                }
            } else {
                yg1.b bVar = yg1.b.a;
                if (cr4.b(gj1VarBx.cb(bVar), b.cb(bVar))) {
                    gj1 b2 = continuation.getB();
                    if (!(l43Var instanceof kg8) && !(l43Var instanceof dp6)) {
                        l43Var = new q5a(l43Var, b2);
                    }
                    Object objA = xu0.a(gj1VarBx, l43Var, wl9.b(gj1VarBx), new C0525cv0(this, null), continuation);
                    if (objA == ck1.a) {
                        return objA;
                    }
                } else {
                    Object objCollect = super.collect(l43Var, continuation);
                    if (objCollect == ck1.a) {
                        return objCollect;
                    }
                }
            }
        }
        return e6a.a;
    }

    @Override // defpackage.vu0
    public final Object d(yi7 yi7Var, Continuation continuation) {
        Object objG = g(new kg8(yi7Var), continuation);
        return objG == ck1.a ? objG : e6a.a;
    }

    public abstract Object g(l43 l43Var, Continuation continuation);

    @Override // defpackage.vu0
    public final String toString() {
        return this.d + " -> " + super.toString();
    }
}