Live Football Updates v1.0.1版本的 MD5 值为：636649089335ebb37514551724606ad0
以下内容为反编译后的 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 f352a;
public Object f353b;
public final h1<Object, Object> f354c;
public final v0 f355d;
public static final class a<T> implements fj.g {
public final r2<a1<Object>> f356a;
public a(r2<a1<Object>> r2Var) {
this.f356a = r2Var;
}
@Override
public final Object a(Object obj, ki.d dVar) {
Object d10 = this.f356a.d((a1) obj, dVar);
if (d10 != li.a.COROUTINE_SUSPENDED) {
return fi.j.f22798a;
}
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 f357a;
public Object f358b;
public final fj.f f359c;
public final fj.f f360d;
public final v0 f361e;
@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 f362a;
public Object f363b;
public Object f364c;
public o f365d;
public final r2<a1<Object>> f366e;
public final v0 f367f;
public a(r2 r2Var, ki.d dVar, v0 v0Var) {
super(4, dVar);
this.f367f = v0Var;
this.f366e = r2Var;
}
@Override
public final Object g(k0 k0Var, a1<Object> a1Var, o oVar, ki.d<? super fi.j> dVar) {
a aVar = new a(this.f366e, dVar, this.f367f);
aVar.f363b = k0Var;
aVar.f364c = a1Var;
aVar.f365d = oVar;
return aVar.invokeSuspend(fi.j.f22798a);
}
@Override
public final Object invokeSuspend(Object obj) {
li.a aVar = li.a.COROUTINE_SUSPENDED;
int i = this.f362a;
if (i != 0) {
if (i == 1) {
b1.a.p(obj);
} else {
throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
}
} else {
b1.a.p(obj);
Object obj2 = this.f363b;
Object obj3 = this.f364c;
o oVar = this.f365d;
Object obj4 = (a1) obj3;
k0 k0Var = (k0) obj2;
o oVar2 = o.RECEIVER;
v0 v0Var = this.f367f;
if (oVar != oVar2) {
if (obj4 instanceof a1.b) {
a1.b bVar = (a1.b) obj4;
v0Var.b(bVar.f221e);
int i10 = bVar.f219c;
int i11 = bVar.f220d;
l0 l0Var = bVar.f217a;
ti.j.f(l0Var, "loadType");
List<y2<T>> list = bVar.f218b;
ti.j.f(list, "pages");
k0 k0Var2 = bVar.f221e;
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.f455c);
} else if (obj4 instanceof a1.c) {
a1.c cVar = (a1.c) obj4;
v0Var.b(cVar.f223a);
obj4 = new a1.c(cVar.f223a, 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.f362a = 1;
if (this.f366e.d(obj4, this) == aVar) {
return aVar;
}
}
return fi.j.f22798a;
}
}
@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 f368a;
public final r2<a1<Object>> f369b;
public final fj.f f370c;
public final AtomicInteger f371d;
public final a3 f372e;
public final int f373f;
public static final class a<T> implements fj.g {
public final a3 f374a;
public final int f375b;
public static final class C0011a extends mi.c {
public Object f376a;
public int f377b;
public C0011a(ki.d dVar) {
super(dVar);
}
@Override
public final Object invokeSuspend(Object obj) {
this.f376a = obj;
this.f377b |= Integer.MIN_VALUE;
return a.this.a(null, this);
}
}
public a(a3 a3Var, int i) {
this.f374a = a3Var;
this.f375b = 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.f377b;
if ((i10 & Integer.MIN_VALUE) != 0) {
c0011a.f377b = i10 - Integer.MIN_VALUE;
Object obj2 = c0011a.f376a;
aVar = li.a.COROUTINE_SUSPENDED;
i = c0011a.f377b;
if (i == 0) {
if (i != 1) {
if (i == 2) {
b1.a.p(obj2);
return fi.j.f22798a;
}
throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
}
b1.a.p(obj2);
} else {
b1.a.p(obj2);
c0011a.f377b = 1;
if (this.f374a.a(this.f375b, obj, c0011a) == aVar) {
return aVar;
}
}
c0011a.f377b = 2;
if (cj.r.m(c0011a) == aVar) {
return aVar;
}
return fi.j.f22798a;
}
}
c0011a = new C0011a(dVar);
Object obj22 = c0011a.f376a;
aVar = li.a.COROUTINE_SUSPENDED;
i = c0011a.f377b;
if (i == 0) {
}
c0011a.f377b = 2;
if (cj.r.m(c0011a) == aVar) {
}
return fi.j.f22798a;
}
}
public C0010b(fj.f fVar, AtomicInteger atomicInteger, r2 r2Var, a3 a3Var, int i, ki.d dVar) {
super(2, dVar);
this.f370c = fVar;
this.f371d = atomicInteger;
this.f372e = a3Var;
this.f373f = i;
this.f369b = r2Var;
}
@Override
public final ki.d<fi.j> create(Object obj, ki.d<?> dVar) {
return new C0010b(this.f370c, this.f371d, this.f369b, this.f372e, this.f373f, dVar);
}
@Override
public final Object invoke(cj.e0 e0Var, ki.d<? super fi.j> dVar) {
return ((C0010b) create(e0Var, dVar)).invokeSuspend(fi.j.f22798a);
}
@Override
public final Object invokeSuspend(Object obj) {
li.a aVar = li.a.COROUTINE_SUSPENDED;
int i = this.f368a;
r2<a1<Object>> r2Var = this.f369b;
AtomicInteger atomicInteger = this.f371d;
try {
if (i != 0) {
if (i == 1) {
b1.a.p(obj);
} else {
throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
}
} else {
b1.a.p(obj);
fj.f fVar = this.f370c;
a aVar2 = new a(this.f372e, this.f373f);
this.f368a = 1;
if (fVar.b(aVar2, this) == aVar) {
return aVar;
}
}
if (atomicInteger.decrementAndGet() == 0) {
r2Var.m(null);
}
return fi.j.f22798a;
} 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 f379b;
public c(cj.o1 o1Var) {
super(0);
this.f379b = o1Var;
}
@Override
public final fi.j invoke() {
this.f379b.c(null);
return fi.j.f22798a;
}
}
public b(fj.f fVar, fj.f fVar2, ki.d dVar, v0 v0Var) {
super(2, dVar);
this.f359c = fVar;
this.f360d = fVar2;
this.f361e = v0Var;
}
@Override
public final ki.d<fi.j> create(Object obj, ki.d<?> dVar) {
b bVar = new b(this.f359c, this.f360d, dVar, this.f361e);
bVar.f358b = 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.f22798a);
}
@Override
public final Object invokeSuspend(Object obj) {
li.a aVar = li.a.COROUTINE_SUSPENDED;
int i = this.f357a;
if (i != 0) {
if (i == 1) {
b1.a.p(obj);
} else {
throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
}
} else {
b1.a.p(obj);
r2 r2Var = (r2) this.f358b;
AtomicInteger atomicInteger = new AtomicInteger(2);
a3 a3Var = new a3(new a(r2Var, null, this.f361e));
cj.o1 d10 = a5.a.d();
int i10 = 0;
fj.f[] fVarArr = {this.f359c, this.f360d};
int i11 = 0;
int i12 = 0;
while (i11 < 2) {
AtomicInteger atomicInteger2 = atomicInteger;
AtomicInteger atomicInteger3 = atomicInteger;
int i13 = i10;
cj.e.b(r2Var, d10, i13, new C0010b(fVarArr[i11], atomicInteger2, r2Var, a3Var, i12, null), 2);
i11++;
i10 = i13;
i12++;
atomicInteger = atomicInteger3;
}
c cVar = new c(d10);
this.f357a = 1;
if (r2Var.y(cVar, this) == aVar) {
return aVar;
}
}
return fi.j.f22798a;
}
}
public g1(o2<Object, Object> o2Var, h1<Object, Object> h1Var, v0 v0Var, ki.d<? super g1> dVar) {
super(2, dVar);
this.f354c = h1Var;
this.f355d = v0Var;
}
@Override
public final ki.d<fi.j> create(Object obj, ki.d<?> dVar) {
g1 g1Var = new g1(null, this.f354c, this.f355d, dVar);
g1Var.f353b = 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.f22798a);
}
@Override
public final Object invokeSuspend(Object obj) {
int i = this.f352a;
if (i != 0) {
if (i == 1) {
b1.a.p(obj);
return fi.j.f22798a;
}
throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
}
b1.a.p(obj);
r2 r2Var = (r2) this.f353b;
throw null;
}
}