Live Football Updates v1.0版本的 MD5 值为：95609b5a5bec0a5f5a0b6e8e4d8f1cba
以下内容为反编译后的 g1.java 源代码，内容仅作参考
package a4;
import a4.a1;
import a4.j0;
import com.google.android.gms.internal.ads.qo1;
import java.util.List;
import java.util.concurrent.atomic.AtomicInteger;
@mi.e(c = "androidx.paging.PageFetcher$injectRemoteEvents$1", f = "PageFetcher.kt", l = {203}, m = "invokeSuspend")
public final class g1 extends mi.i implements si.p<r2<a1<Object>>, ki.d<? super fi.j>, Object> {
public int f349a;
public Object f350b;
public final h1<Object, Object> f351c;
public final v0 f352d;
public static final class a<T> implements fj.g {
public final r2<a1<Object>> f353a;
public a(r2<a1<Object>> r2Var) {
this.f353a = r2Var;
}
@Override
public final Object a(Object obj, ki.d dVar) {
Object d10 = this.f353a.d((a1) obj, dVar);
if (d10 != li.a.COROUTINE_SUSPENDED) {
return fi.j.f22793a;
}
return d10;
}
}
@mi.e(c = "androidx.paging.PageFetcher$injectRemoteEvents$1$invokeSuspend$$inlined$combineWithoutBatching$1", f = "PageFetcher.kt", l = {162}, m = "invokeSuspend")
public static final class b extends mi.i implements si.p<r2<a1<Object>>, ki.d<? super fi.j>, Object> {
public int f354a;
public Object f355b;
public final fj.f f356c;
public final fj.f f357d;
public final v0 f358e;
@mi.e(c = "androidx.paging.PageFetcher$injectRemoteEvents$1$invokeSuspend$$inlined$combineWithoutBatching$1$1", f = "PageFetcher.kt", l = {142}, m = "invokeSuspend")
public static final class a extends mi.i implements si.r<k0, a1<Object>, o, ki.d<? super fi.j>, Object> {
public int f359a;
public Object f360b;
public Object f361c;
public o f362d;
public final r2<a1<Object>> f363e;
public final v0 f364f;
public a(r2 r2Var, ki.d dVar, v0 v0Var) {
super(4, dVar);
this.f364f = v0Var;
this.f363e = r2Var;
}
@Override
public final Object g(k0 k0Var, a1<Object> a1Var, o oVar, ki.d<? super fi.j> dVar) {
a aVar = new a(this.f363e, dVar, this.f364f);
aVar.f360b = k0Var;
aVar.f361c = a1Var;
aVar.f362d = oVar;
return aVar.invokeSuspend(fi.j.f22793a);
}
@Override
public final Object invokeSuspend(Object obj) {
li.a aVar = li.a.COROUTINE_SUSPENDED;
int i = this.f359a;
if (i != 0) {
if (i == 1) {
b1.a.o(obj);
} else {
throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
}
} else {
b1.a.o(obj);
Object obj2 = this.f360b;
Object obj3 = this.f361c;
o oVar = this.f362d;
Object obj4 = (a1) obj3;
k0 k0Var = (k0) obj2;
o oVar2 = o.RECEIVER;
v0 v0Var = this.f364f;
if (oVar != oVar2) {
if (obj4 instanceof a1.b) {
a1.b bVar = (a1.b) obj4;
v0Var.b(bVar.f218e);
int i10 = bVar.f216c;
int i11 = bVar.f217d;
l0 l0Var = bVar.f214a;
ti.j.f(l0Var, "loadType");
List<y2<T>> list = bVar.f215b;
ti.j.f(list, "pages");
k0 k0Var2 = bVar.f218e;
ti.j.f(k0Var2, "sourceLoadStates");
obj4 = new a1.b(l0Var, list, i10, i11, k0Var2, k0Var);
} else if (obj4 instanceof a1.a) {
((a1.a) obj4).getClass();
v0Var.c(null, j0.c.f452c);
} else if (obj4 instanceof a1.c) {
a1.c cVar = (a1.c) obj4;
v0Var.b(cVar.f220a);
obj4 = new a1.c(cVar.f220a, k0Var);
} else if (obj4 instanceof a1.d) {
throw new IllegalStateException("Paging generated an event to display a static list that\n originated from a paginated source. If you see this\n exception, it is most likely a bug in the library.\n Please file a bug so we can fix it at:\n https://issuetracker.google.com/issues/new?component=413106");
} else {
throw new qo1();
}
} else {
obj4 = new a1.c(v0Var.d(), k0Var);
}
this.f359a = 1;
if (this.f363e.d(obj4, this) == aVar) {
return aVar;
}
}
return fi.j.f22793a;
}
}
@mi.e(c = "androidx.paging.FlowExtKt$combineWithoutBatching$2$1$1", f = "FlowExt.kt", l = {148}, m = "invokeSuspend")
public static final class C0010b extends mi.i implements si.p<cj.e0, ki.d<? super fi.j>, Object> {
public int f365a;
public final r2<a1<Object>> f366b;
public final fj.f f367c;
public final AtomicInteger f368d;
public final a3 f369e;
public final int f370f;
public static final class a<T> implements fj.g {
public final a3 f371a;
public final int f372b;
public static final class C0011a extends mi.c {
public Object f373a;
public int f374b;
public C0011a(ki.d dVar) {
super(dVar);
}
@Override
public final Object invokeSuspend(Object obj) {
this.f373a = obj;
this.f374b |= Integer.MIN_VALUE;
return a.this.a(null, this);
}
}
public a(a3 a3Var, int i) {
this.f371a = a3Var;
this.f372b = i;
}
@Override
public final Object a(Object obj, ki.d<? super fi.j> dVar) {
C0011a c0011a;
li.a aVar;
int i;
if (dVar instanceof C0011a) {
c0011a = (C0011a) dVar;
int i10 = c0011a.f374b;
if ((i10 & Integer.MIN_VALUE) != 0) {
c0011a.f374b = i10 - Integer.MIN_VALUE;
Object obj2 = c0011a.f373a;
aVar = li.a.COROUTINE_SUSPENDED;
i = c0011a.f374b;
if (i == 0) {
if (i != 1) {
if (i == 2) {
b1.a.o(obj2);
return fi.j.f22793a;
}
throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
}
b1.a.o(obj2);
} else {
b1.a.o(obj2);
c0011a.f374b = 1;
if (this.f371a.a(this.f372b, obj, c0011a) == aVar) {
return aVar;
}
}
c0011a.f374b = 2;
if (cj.r.m(c0011a) == aVar) {
return aVar;
}
return fi.j.f22793a;
}
}
c0011a = new C0011a(dVar);
Object obj22 = c0011a.f373a;
aVar = li.a.COROUTINE_SUSPENDED;
i = c0011a.f374b;
if (i == 0) {
}
c0011a.f374b = 2;
if (cj.r.m(c0011a) == aVar) {
}
return fi.j.f22793a;
}
}
public C0010b(fj.f fVar, AtomicInteger atomicInteger, r2 r2Var, a3 a3Var, int i, ki.d dVar) {
super(2, dVar);
this.f367c = fVar;
this.f368d = atomicInteger;
this.f369e = a3Var;
this.f370f = i;
this.f366b = r2Var;
}
@Override
public final ki.d<fi.j> create(Object obj, ki.d<?> dVar) {
return new C0010b(this.f367c, this.f368d, this.f366b, this.f369e, this.f370f, dVar);
}
@Override
public final Object invoke(cj.e0 e0Var, ki.d<? super fi.j> dVar) {
return ((C0010b) create(e0Var, dVar)).invokeSuspend(fi.j.f22793a);
}
@Override
public final Object invokeSuspend(Object obj) {
li.a aVar = li.a.COROUTINE_SUSPENDED;
int i = this.f365a;
r2<a1<Object>> r2Var = this.f366b;
AtomicInteger atomicInteger = this.f368d;
try {
if (i != 0) {
if (i == 1) {
b1.a.o(obj);
} else {
throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
}
} else {
b1.a.o(obj);
fj.f fVar = this.f367c;
a aVar2 = new a(this.f369e, this.f370f);
this.f365a = 1;
if (fVar.b(aVar2, this) == aVar) {
return aVar;
}
}
if (atomicInteger.decrementAndGet() == 0) {
r2Var.m(null);
}
return fi.j.f22793a;
} finally {
if (atomicInteger.decrementAndGet() == 0) {
r2Var.m(null);
}
}
}
}
public static final class c extends ti.k implements si.a<fi.j> {
public final cj.s f376b;
public c(cj.o1 o1Var) {
super(0);
this.f376b = o1Var;
}
@Override
public final fi.j invoke() {
this.f376b.c(null);
return fi.j.f22793a;
}
}
public b(fj.f fVar, fj.f fVar2, ki.d dVar, v0 v0Var) {
super(2, dVar);
this.f356c = fVar;
this.f357d = fVar2;
this.f358e = v0Var;
}
@Override
public final ki.d<fi.j> create(Object obj, ki.d<?> dVar) {
b bVar = new b(this.f356c, this.f357d, dVar, this.f358e);
bVar.f355b = obj;
return bVar;
}
@Override
public final Object invoke(r2<a1<Object>> r2Var, ki.d<? super fi.j> dVar) {
return ((b) create(r2Var, dVar)).invokeSuspend(fi.j.f22793a);
}
@Override
public final Object invokeSuspend(Object obj) {
li.a aVar = li.a.COROUTINE_SUSPENDED;
int i = this.f354a;
if (i != 0) {
if (i == 1) {
b1.a.o(obj);
} else {
throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
}
} else {
b1.a.o(obj);
r2 r2Var = (r2) this.f355b;
AtomicInteger atomicInteger = new AtomicInteger(2);
a3 a3Var = new a3(new a(r2Var, null, this.f358e));
cj.o1 b10 = a5.a.b();
int i10 = 0;
fj.f[] fVarArr = {this.f356c, this.f357d};
int i11 = 0;
int i12 = 0;
while (i11 < 2) {
AtomicInteger atomicInteger2 = atomicInteger;
AtomicInteger atomicInteger3 = atomicInteger;
int i13 = i10;
cj.e.b(r2Var, b10, i13, new C0010b(fVarArr[i11], atomicInteger2, r2Var, a3Var, i12, null), 2);
i11++;
i10 = i13;
i12++;
atomicInteger = atomicInteger3;
}
c cVar = new c(b10);
this.f354a = 1;
if (r2Var.y(cVar, this) == aVar) {
return aVar;
}
}
return fi.j.f22793a;
}
}
public g1(o2<Object, Object> o2Var, h1<Object, Object> h1Var, v0 v0Var, ki.d<? super g1> dVar) {
super(2, dVar);
this.f351c = h1Var;
this.f352d = v0Var;
}
@Override
public final ki.d<fi.j> create(Object obj, ki.d<?> dVar) {
g1 g1Var = new g1(null, this.f351c, this.f352d, dVar);
g1Var.f350b = obj;
return g1Var;
}
@Override
public final Object invoke(r2<a1<Object>> r2Var, ki.d<? super fi.j> dVar) {
return ((g1) create(r2Var, dVar)).invokeSuspend(fi.j.f22793a);
}
@Override
public final Object invokeSuspend(Object obj) {
int i = this.f349a;
if (i != 0) {
if (i == 1) {
b1.a.o(obj);
return fi.j.f22793a;
}
throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
}
b1.a.o(obj);
r2 r2Var = (r2) this.f350b;
throw null;
}
}