Proxy Master v3.4.9版本的 MD5 值为:14d0aa2468d13530c8f6e96bcc114bf5

以下内容为反编译后的 r.java 源代码,内容仅作参考


package l0;
public final class r implements bf.f<w<Object>> {
    public final bf.f f27717b;

    @yb.e(c = "androidx.datastore.core.SingleProcessDataStore$data$1$invokeSuspend$$inlined$map$1$2", f = "SingleProcessDataStore.kt", l = {137}, m = "emit")
    public static final class a extends yb.c {
        public Object f27718b;
        public int f27719c;

        public a(wb.d dVar) {
            super(dVar);
        }

        @Override
        public final Object invokeSuspend(Object obj) {
            this.f27718b = obj;
            this.f27719c |= Integer.MIN_VALUE;
            return r.this.emit(null, this);
        }
    }

    public r(bf.f fVar) {
        this.f27717b = fVar;
    }

    @Override
    public final Object emit(w<Object> wVar, wb.d dVar) {
        a aVar;
        int i10;
        if (dVar instanceof a) {
            aVar = (a) dVar;
            int i11 = aVar.f27719c;
            if ((i11 & Integer.MIN_VALUE) != 0) {
                aVar.f27719c = i11 - Integer.MIN_VALUE;
                Object obj = aVar.f27718b;
                xb.a aVar2 = xb.a.f36594b;
                i10 = aVar.f27719c;
                if (i10 != 0) {
                    sb.l.b(obj);
                    w<Object> wVar2 = wVar;
                    if (wVar2 instanceof l) {
                        throw ((l) wVar2).f27639a;
                    }
                    if (wVar2 instanceof j) {
                        throw ((j) wVar2).f27638a;
                    }
                    if (!(wVar2 instanceof c)) {
                        if (wVar2 instanceof x) {
                            throw new IllegalStateException("This is a bug in DataStore. Please file a bug at: https://issuetracker.google.com/issues/new?component=907884&template=1466542".toString());
                        }
                        throw new sb.i();
                    }
                    T t10 = ((c) wVar2).f27618a;
                    aVar.f27719c = 1;
                    if (this.f27717b.emit(t10, aVar) == aVar2) {
                        return aVar2;
                    }
                } else if (i10 != 1) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                } else {
                    sb.l.b(obj);
                }
                return sb.x.f31049a;
            }
        }
        aVar = new a(dVar);
        Object obj2 = aVar.f27718b;
        xb.a aVar22 = xb.a.f36594b;
        i10 = aVar.f27719c;
        if (i10 != 0) {
        }
        return sb.x.f31049a;
    }
}