package defpackage;

/* JADX INFO: renamed from: ʾʩ, reason: contains not printable characters */
/* JADX INFO: loaded from: classes3.dex */
public final class C0213 extends AbstractC3500 implements InterfaceC4965 {

    /* JADX INFO: renamed from: ˈᵲᵢ, reason: contains not printable characters */
    public InterfaceC3822 f1690;

    /* JADX INFO: renamed from: ˌᵨʠᵫ, reason: contains not printable characters */
    public InterfaceC2643 f1691;

    /* JADX INFO: renamed from: ᵨᵼⁱ, reason: contains not printable characters */
    public final InterfaceC4965 f1692;

    /* JADX INFO: renamed from: ᵯᵷʽ, reason: contains not printable characters */
    public final InterfaceC3822 f1693;

    /* JADX INFO: renamed from: ᵶˇᵱ, reason: contains not printable characters */
    public final int f1694;

    public C0213(InterfaceC4965 interfaceC4965, InterfaceC3822 interfaceC3822) {
        super(C3702.f14115, C0887.f3911);
        this.f1692 = interfaceC4965;
        this.f1693 = interfaceC3822;
        this.f1694 = ((Number) interfaceC3822.mo2667(0, new C5549(11))).intValue();
    }

    @Override // defpackage.AbstractC1090
    /* JADX INFO: renamed from: ˊᵙᵾᵲ */
    public final Object mo1078(Object obj) {
        Throwable thM5818 = AbstractC2231.m5818(obj);
        if (thM5818 != null) {
            this.f1690 = new C0743(mo1376(), thM5818);
        }
        InterfaceC2643 interfaceC2643 = this.f1691;
        if (interfaceC2643 != null) {
            interfaceC2643.mo3530(obj);
        }
        return EnumC0111.f1384;
    }

    /* JADX INFO: renamed from: ˏːˆ, reason: contains not printable characters */
    public final Object m1375(InterfaceC2643 interfaceC2643, Object obj) {
        InterfaceC3822 interfaceC3822Mo1376 = interfaceC2643.mo1376();
        AbstractC3481.m7932(interfaceC3822Mo1376);
        InterfaceC3822 interfaceC3822 = this.f1690;
        if (interfaceC3822 != interfaceC3822Mo1376) {
            if (interfaceC3822 instanceof C0743) {
                throw new IllegalStateException(AbstractC1555.m4401("\n            Flow exception transparency is violated:\n                Previous 'emit' call has thrown exception " + ((C0743) interfaceC3822).f3358 + ", but then emission attempt of value '" + obj + "' has been detected.\n                Emissions from 'catch' blocks are prohibited in order to avoid unspecified behaviour, 'Flow.catch' operator can be used instead.\n                For a more detailed explanation, please refer to Flow documentation.\n            ").toString());
            }
            if (((Number) interfaceC3822Mo1376.mo2667(0, new ˇᵤᵜˈ(8, this))).intValue() != this.f1694) {
                throw new IllegalStateException(("Flow invariant is violated:\n\t\tFlow was collected in " + this.f1693 + ",\n\t\tbut emission happened in " + interfaceC3822Mo1376 + ".\n\t\tPlease refer to 'flow' documentation or use 'flowOn' instead").toString());
            }
            this.f1690 = interfaceC3822Mo1376;
        }
        this.f1691 = interfaceC2643;
        Object objMo1175 = AbstractC4849.f18507.mo1175(this.f1692, obj, this);
        if (!ᵥˈᵛ.ˊᵫᵗ(objMo1175, EnumC0111.f1384)) {
            this.f1691 = null;
        }
        return objMo1175;
    }

    @Override // defpackage.AbstractC3500, defpackage.InterfaceC2643
    /* JADX INFO: renamed from: ᵮᵣᵗˈ, reason: contains not printable characters */
    public final InterfaceC3822 mo1376() {
        InterfaceC3822 interfaceC3822 = this.f1690;
        return interfaceC3822 == null ? C0887.f3911 : interfaceC3822;
    }

    @Override // defpackage.AbstractC1090
    /* JADX INFO: renamed from: ᵱʡˏ, reason: contains not printable characters */
    public final StackTraceElement mo1377() {
        return null;
    }

    @Override // defpackage.InterfaceC4965
    /* JADX INFO: renamed from: ᵶᵥᵝ, reason: contains not printable characters */
    public final Object mo1378(Object obj, InterfaceC2643 interfaceC2643) {
        try {
            Object objM1375 = m1375(interfaceC2643, obj);
            return objM1375 == EnumC0111.f1384 ? objM1375 : C5063.f19112;
        } catch (Throwable th) {
            this.f1690 = new C0743(interfaceC2643.mo1376(), th);
            throw th;
        }
    }

    @Override // defpackage.AbstractC1090, defpackage.InterfaceC3912
    /* JADX INFO: renamed from: ᵷᵺʾᵖ, reason: contains not printable characters */
    public final InterfaceC3912 mo1379() {
        InterfaceC2643 interfaceC2643 = this.f1691;
        if (interfaceC2643 instanceof InterfaceC3912) {
            return (InterfaceC3912) interfaceC2643;
        }
        return null;
    }
}
