package c7;

import b7.EnumC0551a;
import c6.C0588d;
import com.google.android.gms.internal.measurement.C1;

/* JADX INFO: renamed from: c7.c, reason: case insensitive filesystem */
/* JADX INFO: loaded from: classes.dex */
public final class C0595c extends d7.g {

    /* JADX INFO: renamed from: t, reason: collision with root package name */
    public final C0588d f9414t;

    /* JADX INFO: renamed from: u, reason: collision with root package name */
    public final C0588d f9415u;

    public C0595c(C0588d c0588d, E6.i iVar, int i, EnumC0551a enumC0551a) {
        super(iVar, i, enumC0551a);
        this.f9414t = c0588d;
        this.f9415u = c0588d;
    }

    /* JADX WARN: Removed duplicated region for block: B:7:0x0013  */
    @Override // d7.g
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final Object a(b7.u uVar, E6.d dVar) throws Throwable {
        C0594b c0594b;
        if (dVar instanceof C0594b) {
            c0594b = (C0594b) dVar;
            int i = c0594b.f9413w;
            if ((i & Integer.MIN_VALUE) != 0) {
                c0594b.f9413w = i - Integer.MIN_VALUE;
            } else {
                c0594b = new C0594b(this, (G6.c) dVar);
            }
        }
        Object obj = c0594b.f9411u;
        F6.a aVar = F6.a.f2580q;
        int i5 = c0594b.f9413w;
        A6.n nVar = A6.n.f457a;
        if (i5 == 0) {
            C1.N(obj);
            c0594b.f9410t = uVar;
            c0594b.f9413w = 1;
            Object objK = this.f9414t.k(uVar, c0594b);
            if (objK != aVar) {
                objK = nVar;
            }
            if (objK == aVar) {
                return aVar;
            }
        } else {
            if (i5 != 1) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            uVar = c0594b.f9410t;
            C1.N(obj);
        }
        if (((b7.t) uVar).f9273t.u()) {
            return nVar;
        }
        throw new IllegalStateException("'awaitClose { yourCallbackOrListener.cancel() }' should be used in the end of callbackFlow block.\nOtherwise, a callback/listener may leak in case of external cancellation.\nSee callbackFlow API documentation for the details.");
    }

    @Override // d7.g
    public final d7.g b(E6.i iVar, int i, EnumC0551a enumC0551a) {
        return new C0595c(this.f9415u, iVar, i, enumC0551a);
    }

    @Override // d7.g
    public final String toString() {
        return "block[" + this.f9414t + "] -> " + super.toString();
    }
}
