PhotoRoom v4.8.2版本的 MD5 值为：c40a01bb3380c0f75c0cb6ac6760f295
以下内容为反编译后的 h0.java 源代码，内容仅作参考
package s4;
import androidx.recyclerview.widget.LinearLayoutManager;
import b10.e2;
import b10.k2;
import b10.q3;
import d10.z;
import java.util.List;
import java.util.concurrent.atomic.AtomicInteger;
import s4.g0;
import s4.v0;
import s4.x;
public final class h0 {
private final hy.l f69789a;
private final Object f69790b;
private final o0 f69791c;
private final i f69792d;
private final i f69793e;
private final e10.h f69794f;
public static final class a {
private final i0 f69795a;
private final u0 f69796b;
private final e2 f69797c;
public a(i0 snapshot, u0 u0Var, e2 job) {
kotlin.jvm.internal.t.i(snapshot, "snapshot");
kotlin.jvm.internal.t.i(job, "job");
this.f69795a = snapshot;
this.f69796b = u0Var;
this.f69797c = job;
}
public final e2 a() {
return this.f69797c;
}
public final i0 b() {
return this.f69795a;
}
public final u0 c() {
return this.f69796b;
}
}
public final class b implements s {
private final i0 f69798a;
final h0 f69799b;
public b(h0 h0Var, i0 pageFetcherSnapshot) {
kotlin.jvm.internal.t.i(pageFetcherSnapshot, "pageFetcherSnapshot");
this.f69799b = h0Var;
this.f69798a = pageFetcherSnapshot;
}
@Override
public void a(f1 viewportHint) {
kotlin.jvm.internal.t.i(viewportHint, "viewportHint");
this.f69798a.o(viewportHint);
}
}
public final class c implements d1 {
private final i f69800a;
final h0 f69801b;
public c(h0 h0Var, i retryEventBus) {
kotlin.jvm.internal.t.i(retryEventBus, "retryEventBus");
this.f69801b = h0Var;
this.f69800a = retryEventBus;
}
@Override
public void a() {
this.f69800a.b(px.f1.f64673a);
}
@Override
public void b() {
this.f69801b.l();
}
}
static final class d extends kotlin.coroutines.jvm.internal.m implements hy.p {
int f69802h;
private Object f69803i;
final h0 f69804j;
public static final class a extends kotlin.coroutines.jvm.internal.m implements hy.p {
int f69805h;
private Object f69806i;
final w0 f69807j;
a(w0 w0Var, ux.d dVar) {
super(2, dVar);
this.f69807j = w0Var;
}
@Override
public final ux.d create(Object obj, ux.d dVar) {
a aVar = new a(this.f69807j, dVar);
aVar.f69806i = obj;
return aVar;
}
@Override
public final Object invoke(e10.i iVar, ux.d dVar) {
return ((a) create(iVar, dVar)).invokeSuspend(px.f1.f64673a);
}
@Override
public final Object invokeSuspend(Object obj) {
Object e11;
e10.i iVar;
v0.a aVar;
Boolean a11;
e11 = vx.d.e();
int i11 = this.f69805h;
if (i11 == 0) {
px.n0.b(obj);
iVar = (e10.i) this.f69806i;
w0 w0Var = this.f69807j;
if (w0Var == null) {
aVar = null;
a11 = kotlin.coroutines.jvm.internal.b.a(aVar == v0.a.LAUNCH_INITIAL_REFRESH);
this.f69806i = null;
this.f69805h = 2;
if (iVar.emit(a11, this) == e11) {
return e11;
}
return px.f1.f64673a;
}
this.f69806i = iVar;
this.f69805h = 1;
obj = w0Var.a(this);
if (obj == e11) {
return e11;
}
} else if (i11 != 1) {
if (i11 == 2) {
px.n0.b(obj);
return px.f1.f64673a;
}
throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
} else {
iVar = (e10.i) this.f69806i;
px.n0.b(obj);
}
aVar = (v0.a) obj;
a11 = kotlin.coroutines.jvm.internal.b.a(aVar == v0.a.LAUNCH_INITIAL_REFRESH);
this.f69806i = null;
this.f69805h = 2;
if (iVar.emit(a11, this) == e11) {
}
return px.f1.f64673a;
}
}
public static final class b extends kotlin.coroutines.jvm.internal.m implements hy.q {
Object f69808h;
int f69809i;
Object f69810j;
boolean f69811k;
final w0 f69812l;
final h0 f69813m;
public class a extends kotlin.jvm.internal.q implements hy.a {
a(Object obj) {
super(0, obj, h0.class, "refresh", "refresh()V", 0);
}
@Override
public Object invoke() {
m15077invoke();
return px.f1.f64673a;
}
public final void m15077invoke() {
((h0) this.receiver).l();
}
}
b(w0 w0Var, h0 h0Var, ux.d dVar) {
super(3, dVar);
this.f69812l = w0Var;
this.f69813m = h0Var;
}
public final Object d(a aVar, boolean z11, ux.d dVar) {
b bVar = new b(this.f69812l, this.f69813m, dVar);
bVar.f69810j = aVar;
bVar.f69811k = z11;
return bVar.invokeSuspend(px.f1.f64673a);
}
@Override
public Object invoke(Object obj, Object obj2, Object obj3) {
return d((a) obj, ((Boolean) obj2).booleanValue(), (ux.d) obj3);
}
@Override
public final Object invokeSuspend(Object obj) {
Object e11;
a aVar;
i0 b11;
w0 w0Var;
s0 s0Var;
u0 u0Var;
i0 b12;
s0 s0Var2;
List b13;
Object refreshKey;
b10.a0 b14;
e2 a11;
i0 b15;
u0 c11;
u0 c12;
List b16;
e11 = vx.d.e();
int i11 = this.f69809i;
if (i11 == 0) {
px.n0.b(obj);
a aVar2 = (a) this.f69810j;
if (this.f69811k && (w0Var = this.f69812l) != null) {
w0Var.b();
}
h0 h0Var = this.f69813m;
s0 v11 = (aVar2 == null || (b11 = aVar2.b()) == null) ? null : b11.v();
this.f69810j = aVar2;
this.f69809i = 1;
Object h11 = h0Var.h(v11, this);
if (h11 == e11) {
return e11;
}
aVar = aVar2;
obj = h11;
} else if (i11 != 1) {
if (i11 == 2) {
s0Var2 = (s0) this.f69808h;
aVar = (a) this.f69810j;
px.n0.b(obj);
u0Var = (u0) obj;
s0Var = s0Var2;
b13 = u0Var != null ? u0Var.b() : null;
boolean z11 = false;
if (b13 != null || b13.isEmpty()) {
if ((aVar == null || (c12 = aVar.c()) == null || (b16 = c12.b()) == null || !(b16.isEmpty() ^ true)) ? false : true) {
u0Var = aVar.c();
}
}
if ((u0Var != null ? u0Var.a() : null) == null) {
if (((aVar == null || (c11 = aVar.c()) == null) ? null : c11.a()) != null) {
u0Var = aVar.c();
}
}
if (u0Var == null) {
refreshKey = this.f69813m.f69790b;
} else {
refreshKey = s0Var.getRefreshKey(u0Var);
a0 a12 = b0.a();
if (a12 != null && a12.b(3)) {
z11 = true;
}
if (z11) {
a12.a(3, "Refresh key " + refreshKey + " returned from PagingSource " + s0Var, null);
}
}
Object obj2 = refreshKey;
if (aVar != null && (b15 = aVar.b()) != null) {
b15.p();
}
if (aVar != null && (a11 = aVar.a()) != null) {
e2.a.a(a11, null, 1, null);
}
i0 i0Var = new i0(obj2, s0Var, this.f69813m.f69791c, this.f69813m.f69793e.a(), this.f69812l, u0Var, new a(this.f69813m));
b14 = k2.b(null, 1, null);
return new a(i0Var, u0Var, b14);
}
throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
} else {
aVar = (a) this.f69810j;
px.n0.b(obj);
}
s0 s0Var3 = (s0) obj;
if (aVar == null || (b12 = aVar.b()) == null) {
s0Var = s0Var3;
u0Var = null;
b13 = u0Var != null ? u0Var.b() : null;
boolean z112 = false;
if (b13 != null || b13.isEmpty()) {
}
if ((u0Var != null ? u0Var.a() : null) == null) {
}
if (u0Var == null) {
}
Object obj22 = refreshKey;
if (aVar != null) {
b15.p();
}
if (aVar != null) {
e2.a.a(a11, null, 1, null);
}
i0 i0Var2 = new i0(obj22, s0Var, this.f69813m.f69791c, this.f69813m.f69793e.a(), this.f69812l, u0Var, new a(this.f69813m));
b14 = k2.b(null, 1, null);
return new a(i0Var2, u0Var, b14);
}
this.f69810j = aVar;
this.f69808h = s0Var3;
this.f69809i = 2;
Object r11 = b12.r(this);
if (r11 == e11) {
return e11;
}
s0Var2 = s0Var3;
obj = r11;
u0Var = (u0) obj;
s0Var = s0Var2;
b13 = u0Var != null ? u0Var.b() : null;
boolean z1122 = false;
if (b13 != null || b13.isEmpty()) {
}
if ((u0Var != null ? u0Var.a() : null) == null) {
}
if (u0Var == null) {
}
Object obj222 = refreshKey;
if (aVar != null) {
}
if (aVar != null) {
}
i0 i0Var22 = new i0(obj222, s0Var, this.f69813m.f69791c, this.f69813m.f69793e.a(), this.f69812l, u0Var, new a(this.f69813m));
b14 = k2.b(null, 1, null);
return new a(i0Var22, u0Var, b14);
}
}
public static final class c extends kotlin.coroutines.jvm.internal.m implements hy.p {
int f69814h;
Object f69815i;
c(ux.d dVar) {
super(2, dVar);
}
@Override
public final ux.d create(Object obj, ux.d dVar) {
c cVar = new c(dVar);
cVar.f69815i = obj;
return cVar;
}
@Override
public final Object invoke(g0 g0Var, ux.d dVar) {
return ((c) create(g0Var, dVar)).invokeSuspend(px.f1.f64673a);
}
@Override
public final Object invokeSuspend(Object obj) {
vx.d.e();
if (this.f69814h == 0) {
px.n0.b(obj);
g0 g0Var = (g0) this.f69815i;
a0 a11 = b0.a();
boolean z11 = false;
if (a11 != null && a11.b(2)) {
z11 = true;
}
if (z11) {
a11.a(2, "Sent " + g0Var, null);
}
return px.f1.f64673a;
}
throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
}
}
public class C2242d implements e10.i, kotlin.jvm.internal.n {
final z0 f69816b;
C2242d(z0 z0Var) {
this.f69816b = z0Var;
}
@Override
public final px.r b() {
return new kotlin.jvm.internal.q(2, this.f69816b, z0.class, "send", "send(Ljava/lang/Object;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;", 0);
}
@Override
public final Object emit(p0 p0Var, ux.d dVar) {
Object e11;
Object d11 = this.f69816b.d(p0Var, dVar);
e11 = vx.d.e();
return d11 == e11 ? d11 : px.f1.f64673a;
}
public final boolean equals(Object obj) {
if ((obj instanceof e10.i) && (obj instanceof kotlin.jvm.internal.n)) {
return kotlin.jvm.internal.t.d(b(), ((kotlin.jvm.internal.n) obj).b());
}
return false;
}
public final int hashCode() {
return b().hashCode();
}
}
public static final class e extends kotlin.coroutines.jvm.internal.m implements hy.q {
int f69817h;
private Object f69818i;
Object f69819j;
final h0 f69820k;
final w0 f69821l;
public e(ux.d dVar, h0 h0Var, w0 w0Var) {
super(3, dVar);
this.f69820k = h0Var;
this.f69821l = w0Var;
}
@Override
public final Object invoke(e10.i iVar, Object obj, ux.d dVar) {
e eVar = new e(dVar, this.f69820k, this.f69821l);
eVar.f69818i = iVar;
eVar.f69819j = obj;
return eVar.invokeSuspend(px.f1.f64673a);
}
@Override
public final Object invokeSuspend(Object obj) {
Object e11;
e11 = vx.d.e();
int i11 = this.f69817h;
if (i11 == 0) {
px.n0.b(obj);
a aVar = (a) this.f69819j;
e10.h O = e10.j.O(this.f69820k.j(aVar.b(), aVar.a(), this.f69821l), new c(null));
h0 h0Var = this.f69820k;
p0 p0Var = new p0(O, new c(h0Var, h0Var.f69793e), new b(this.f69820k, aVar.b()), null, 8, null);
this.f69817h = 1;
if (((e10.i) this.f69818i).emit(p0Var, this) == e11) {
return e11;
}
} else if (i11 != 1) {
throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
} else {
px.n0.b(obj);
}
return px.f1.f64673a;
}
}
d(v0 v0Var, h0 h0Var, ux.d dVar) {
super(2, dVar);
this.f69804j = h0Var;
}
@Override
public final ux.d create(Object obj, ux.d dVar) {
d dVar2 = new d(null, this.f69804j, dVar);
dVar2.f69803i = obj;
return dVar2;
}
@Override
public final Object invoke(z0 z0Var, ux.d dVar) {
return ((d) create(z0Var, dVar)).invokeSuspend(px.f1.f64673a);
}
@Override
public final Object invokeSuspend(Object obj) {
Object e11;
e11 = vx.d.e();
int i11 = this.f69802h;
if (i11 == 0) {
px.n0.b(obj);
e10.h d11 = o.d(e10.j.y(o.c(e10.j.P(this.f69804j.f69792d.a(), new a(null, null)), null, new b(null, this.f69804j, null))), new e(null, this.f69804j, null));
C2242d c2242d = new C2242d((z0) this.f69803i);
this.f69802h = 1;
if (d11.collect(c2242d, this) == e11) {
return e11;
}
} else if (i11 != 1) {
throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
} else {
px.n0.b(obj);
}
return px.f1.f64673a;
}
}
public static final class e extends kotlin.coroutines.jvm.internal.d {
Object f69822h;
Object f69823i;
Object f69824j;
int f69826l;
e(ux.d dVar) {
super(dVar);
}
@Override
public final Object invokeSuspend(Object obj) {
this.f69824j = obj;
this.f69826l |= LinearLayoutManager.INVALID_OFFSET;
return h0.this.h(null, this);
}
}
public class f extends kotlin.jvm.internal.q implements hy.a {
f(Object obj) {
super(0, obj, h0.class, "invalidate", "invalidate()V", 0);
}
@Override
public Object invoke() {
m15078invoke();
return px.f1.f64673a;
}
public final void m15078invoke() {
((h0) this.receiver).k();
}
}
public class g extends kotlin.jvm.internal.q implements hy.a {
g(Object obj) {
super(0, obj, h0.class, "invalidate", "invalidate()V", 0);
}
@Override
public Object invoke() {
m15079invoke();
return px.f1.f64673a;
}
public final void m15079invoke() {
((h0) this.receiver).k();
}
}
public static final class h extends kotlin.coroutines.jvm.internal.m implements hy.p {
int f69827h;
private Object f69828i;
final w0 f69829j;
final i0 f69830k;
final e0 f69831l;
public static final class a implements e10.i {
final z0 f69832b;
a(z0 z0Var) {
this.f69832b = z0Var;
}
@Override
public final Object emit(g0 g0Var, ux.d dVar) {
Object e11;
Object d11 = this.f69832b.d(g0Var, dVar);
e11 = vx.d.e();
return d11 == e11 ? d11 : px.f1.f64673a;
}
}
public static final class b extends kotlin.coroutines.jvm.internal.m implements hy.p {
int f69833h;
private Object f69834i;
final e10.h f69835j;
final e10.h f69836k;
final e0 f69837l;
public static final class a extends kotlin.coroutines.jvm.internal.m implements hy.r {
int f69838h;
Object f69839i;
Object f69840j;
Object f69841k;
final z0 f69842l;
final e0 f69843m;
public a(z0 z0Var, ux.d dVar, e0 e0Var) {
super(4, dVar);
this.f69843m = e0Var;
this.f69842l = z0Var;
}
@Override
public final Object invoke(Object obj, Object obj2, s4.g gVar, ux.d dVar) {
a aVar = new a(this.f69842l, dVar, this.f69843m);
aVar.f69839i = obj;
aVar.f69840j = obj2;
aVar.f69841k = gVar;
return aVar.invokeSuspend(px.f1.f64673a);
}
@Override
public final Object invokeSuspend(Object obj) {
Object e11;
e11 = vx.d.e();
int i11 = this.f69838h;
if (i11 == 0) {
px.n0.b(obj);
Object obj2 = this.f69839i;
Object obj3 = this.f69840j;
s4.g gVar = (s4.g) this.f69841k;
z0 z0Var = this.f69842l;
Object obj4 = (g0) obj3;
y yVar = (y) obj2;
if (gVar == s4.g.RECEIVER) {
obj4 = new g0.c(this.f69843m.d(), yVar);
} else if (obj4 instanceof g0.b) {
g0.b bVar = (g0.b) obj4;
this.f69843m.b(bVar.k());
obj4 = g0.b.e(bVar, null, null, 0, 0, bVar.k(), yVar, 15, null);
} else if (obj4 instanceof g0.a) {
this.f69843m.c(((g0.a) obj4).c(), x.c.f70182b.b());
} else if (!(obj4 instanceof g0.c)) {
if (obj4 instanceof g0.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");
}
throw new px.c0();
} else {
g0.c cVar = (g0.c) obj4;
this.f69843m.b(cVar.d());
obj4 = new g0.c(cVar.d(), yVar);
}
this.f69838h = 1;
if (z0Var.d(obj4, this) == e11) {
return e11;
}
} else if (i11 != 1) {
throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
} else {
px.n0.b(obj);
}
return px.f1.f64673a;
}
}
public static final class C2243b extends kotlin.coroutines.jvm.internal.m implements hy.p {
int f69844h;
final z0 f69845i;
final e10.h f69846j;
final AtomicInteger f69847k;
final e1 f69848l;
final int f69849m;
public static final class a implements e10.i {
final e1 f69850b;
final int f69851c;
public static final class C2244a extends kotlin.coroutines.jvm.internal.d {
Object f69852h;
int f69853i;
C2244a(ux.d dVar) {
super(dVar);
}
@Override
public final Object invokeSuspend(Object obj) {
this.f69852h = obj;
this.f69853i |= LinearLayoutManager.INVALID_OFFSET;
return a.this.emit(null, this);
}
}
public a(e1 e1Var, int i11) {
this.f69850b = e1Var;
this.f69851c = i11;
}
@Override
public final Object emit(Object obj, ux.d dVar) {
C2244a c2244a;
Object e11;
int i11;
if (dVar instanceof C2244a) {
c2244a = (C2244a) dVar;
int i12 = c2244a.f69853i;
if ((i12 & LinearLayoutManager.INVALID_OFFSET) != 0) {
c2244a.f69853i = i12 - LinearLayoutManager.INVALID_OFFSET;
Object obj2 = c2244a.f69852h;
e11 = vx.d.e();
i11 = c2244a.f69853i;
if (i11 != 0) {
px.n0.b(obj2);
e1 e1Var = this.f69850b;
int i13 = this.f69851c;
c2244a.f69853i = 1;
if (e1Var.a(i13, obj, c2244a) == e11) {
return e11;
}
} else if (i11 != 1) {
if (i11 == 2) {
px.n0.b(obj2);
return px.f1.f64673a;
}
throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
} else {
px.n0.b(obj2);
}
c2244a.f69853i = 2;
if (q3.a(c2244a) == e11) {
return e11;
}
return px.f1.f64673a;
}
}
c2244a = new C2244a(dVar);
Object obj22 = c2244a.f69852h;
e11 = vx.d.e();
i11 = c2244a.f69853i;
if (i11 != 0) {
}
c2244a.f69853i = 2;
if (q3.a(c2244a) == e11) {
}
return px.f1.f64673a;
}
}
public C2243b(e10.h hVar, AtomicInteger atomicInteger, z0 z0Var, e1 e1Var, int i11, ux.d dVar) {
super(2, dVar);
this.f69846j = hVar;
this.f69847k = atomicInteger;
this.f69848l = e1Var;
this.f69849m = i11;
this.f69845i = z0Var;
}
@Override
public final ux.d create(Object obj, ux.d dVar) {
return new C2243b(this.f69846j, this.f69847k, this.f69845i, this.f69848l, this.f69849m, dVar);
}
@Override
public final Object invoke(b10.o0 o0Var, ux.d dVar) {
return ((C2243b) create(o0Var, dVar)).invokeSuspend(px.f1.f64673a);
}
@Override
public final Object invokeSuspend(Object obj) {
Object e11;
AtomicInteger atomicInteger;
e11 = vx.d.e();
int i11 = this.f69844h;
try {
if (i11 == 0) {
px.n0.b(obj);
e10.h hVar = this.f69846j;
a aVar = new a(this.f69848l, this.f69849m);
this.f69844h = 1;
if (hVar.collect(aVar, this) == e11) {
return e11;
}
} else if (i11 != 1) {
throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
} else {
px.n0.b(obj);
}
if (atomicInteger.decrementAndGet() == 0) {
z.a.a(this.f69845i, null, 1, null);
}
return px.f1.f64673a;
} finally {
if (this.f69847k.decrementAndGet() == 0) {
z.a.a(this.f69845i, null, 1, null);
}
}
}
}
public static final class c extends kotlin.jvm.internal.v implements hy.a {
final b10.a0 f69855g;
public c(b10.a0 a0Var) {
super(0);
this.f69855g = a0Var;
}
@Override
public Object invoke() {
m15080invoke();
return px.f1.f64673a;
}
public final void m15080invoke() {
e2.a.a(this.f69855g, null, 1, null);
}
}
public b(e10.h hVar, e10.h hVar2, ux.d dVar, e0 e0Var) {
super(2, dVar);
this.f69835j = hVar;
this.f69836k = hVar2;
this.f69837l = e0Var;
}
@Override
public final ux.d create(Object obj, ux.d dVar) {
b bVar = new b(this.f69835j, this.f69836k, dVar, this.f69837l);
bVar.f69834i = obj;
return bVar;
}
@Override
public final Object invoke(z0 z0Var, ux.d dVar) {
return ((b) create(z0Var, dVar)).invokeSuspend(px.f1.f64673a);
}
@Override
public final Object invokeSuspend(Object obj) {
Object e11;
b10.a0 b11;
e11 = vx.d.e();
int i11 = this.f69833h;
if (i11 == 0) {
px.n0.b(obj);
z0 z0Var = (z0) this.f69834i;
AtomicInteger atomicInteger = new AtomicInteger(2);
e1 e1Var = new e1(new a(z0Var, null, this.f69837l));
b11 = k2.b(null, 1, null);
e10.h[] hVarArr = {this.f69835j, this.f69836k};
int i12 = 0;
int i13 = 0;
while (i13 < 2) {
b10.k.d(z0Var, b11, null, new C2243b(hVarArr[i13], atomicInteger, z0Var, e1Var, i12, null), 2, null);
i13++;
i12++;
}
c cVar = new c(b11);
this.f69833h = 1;
if (z0Var.m(cVar, this) == e11) {
return e11;
}
} else if (i11 != 1) {
throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
} else {
px.n0.b(obj);
}
return px.f1.f64673a;
}
}
h(w0 w0Var, i0 i0Var, e0 e0Var, ux.d dVar) {
super(2, dVar);
this.f69829j = w0Var;
this.f69830k = i0Var;
this.f69831l = e0Var;
}
@Override
public final ux.d create(Object obj, ux.d dVar) {
h hVar = new h(this.f69829j, this.f69830k, this.f69831l, dVar);
hVar.f69828i = obj;
return hVar;
}
@Override
public final Object invoke(z0 z0Var, ux.d dVar) {
return ((h) create(z0Var, dVar)).invokeSuspend(px.f1.f64673a);
}
@Override
public final Object invokeSuspend(Object obj) {
Object e11;
e11 = vx.d.e();
int i11 = this.f69827h;
if (i11 == 0) {
px.n0.b(obj);
e10.h a11 = y0.a(new b(this.f69829j.getState(), this.f69830k.u(), null, this.f69831l));
a aVar = new a((z0) this.f69828i);
this.f69827h = 1;
if (a11.collect(aVar, this) == e11) {
return e11;
}
} else if (i11 != 1) {
throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
} else {
px.n0.b(obj);
}
return px.f1.f64673a;
}
}
public h0(hy.l pagingSourceFactory, Object obj, o0 config, v0 v0Var) {
kotlin.jvm.internal.t.i(pagingSourceFactory, "pagingSourceFactory");
kotlin.jvm.internal.t.i(config, "config");
this.f69789a = pagingSourceFactory;
this.f69790b = obj;
this.f69791c = config;
this.f69792d = new i(null, 1, null);
this.f69793e = new i(null, 1, null);
this.f69794f = y0.a(new d(v0Var, this, null));
}
public final Object h(s0 s0Var, ux.d dVar) {
e eVar;
Object e11;
int i11;
h0 h0Var;
s0 s0Var2;
if (dVar instanceof e) {
eVar = (e) dVar;
int i12 = eVar.f69826l;
if ((i12 & LinearLayoutManager.INVALID_OFFSET) != 0) {
eVar.f69826l = i12 - LinearLayoutManager.INVALID_OFFSET;
Object obj = eVar.f69824j;
e11 = vx.d.e();
i11 = eVar.f69826l;
boolean z11 = true;
if (i11 != 0) {
px.n0.b(obj);
hy.l lVar = this.f69789a;
eVar.f69822h = this;
eVar.f69823i = s0Var;
eVar.f69826l = 1;
obj = lVar.invoke(eVar);
if (obj == e11) {
return e11;
}
h0Var = this;
} else if (i11 != 1) {
throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
} else {
s0Var = (s0) eVar.f69823i;
h0Var = (h0) eVar.f69822h;
px.n0.b(obj);
}
s0Var2 = (s0) obj;
if (s0Var2 == s0Var) {
throw new IllegalStateException("An instance of PagingSource was re-used when Pager expected to create a new\ninstance. Ensure that the pagingSourceFactory passed to Pager always returns a\nnew instance of PagingSource.".toString());
}
s0Var2.registerInvalidatedCallback(new f(h0Var));
if (s0Var != null) {
s0Var.unregisterInvalidatedCallback(new g(h0Var));
}
if (s0Var != null) {
s0Var.invalidate();
}
a0 a11 = b0.a();
if (a11 == null || !a11.b(3)) {
z11 = false;
}
if (z11) {
a11.a(3, "Generated new PagingSource " + s0Var2, null);
}
return s0Var2;
}
}
eVar = new e(dVar);
Object obj2 = eVar.f69824j;
e11 = vx.d.e();
i11 = eVar.f69826l;
boolean z112 = true;
if (i11 != 0) {
}
s0Var2 = (s0) obj2;
if (s0Var2 == s0Var) {
}
}
public final e10.h j(i0 i0Var, e2 e2Var, w0 w0Var) {
return w0Var == null ? i0Var.u() : s4.e.a(e2Var, new h(w0Var, i0Var, new e0(), null));
}
public final void k() {
this.f69792d.b(Boolean.FALSE);
}
public final e10.h i() {
return this.f69794f;
}
public final void l() {
this.f69792d.b(Boolean.TRUE);
}
}