package com.strmr.ps.ui.base;

import defpackage.ak1;
import defpackage.ck1;
import defpackage.e6a;
import defpackage.gf1;
import defpackage.gr3;
import defpackage.hl4;
import defpackage.mg6;
import defpackage.n89;
import defpackage.ng6;
import defpackage.s38;
import defpackage.vx8;
import defpackage.y41;
import java.util.Iterator;
import java.util.List;
import kotlin.Metadata;
import kotlin.coroutines.Continuation;
import kotlin.coroutines.jvm.internal.DebugMetadata;
import kotlin.coroutines.jvm.internal.SuspendLambda;

/* JADX INFO: loaded from: classes3.dex */
@Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0002\u001a\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0002\u0010\u0003"}, d2 = {"Lak1;", "Le6a;", "<anonymous>", "(Lak1;)V"}, k = 3, mv = {2, 0, 0})
@DebugMetadata(c = "com.strmr.ps.ui.base.BaseContentViewModel$reloadContinueWatchingFromCache$1", f = "BaseContentViewModel.kt", i = {0}, l = {881, 774}, m = "invokeSuspend", n = {"$this$withLock_u24default$iv"}, s = {"L$0"})
@vx8
final class s extends SuspendLambda implements gr3<ak1, Continuation<? super e6a>, Object> {
    public Object a;
    public Object b;
    public int c;
    public final /* synthetic */ BaseContentViewModel d;

    /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
    public s(BaseContentViewModel baseContentViewModel, Continuation continuation) {
        super(2, continuation);
        this.d = baseContentViewModel;
    }

    @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
    public final Continuation create(Object obj, Continuation continuation) {
        return new s(this.d, continuation);
    }

    @Override // defpackage.gr3
    public final Object invoke(Object obj, Object obj2) {
        return ((s) create((ak1) obj, (Continuation) obj2)).invokeSuspend(e6a.a);
    }

    /* JADX WARN: Removed duplicated region for block: B:19:0x0063  */
    @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final Object invokeSuspend(Object obj) {
        mg6 mg6Var;
        BaseContentViewModel baseContentViewModel;
        Iterator it;
        ck1 ck1Var = ck1.a;
        int i = this.c;
        BaseContentViewModel baseContentViewModel2 = this.d;
        try {
            if (i == 0) {
                s38.b(obj);
                ng6 ng6Var = baseContentViewModel2.j;
                this.a = ng6Var;
                this.b = baseContentViewModel2;
                this.c = 1;
                if (ng6Var.a(this) != ck1Var) {
                    mg6Var = ng6Var;
                    baseContentViewModel = baseContentViewModel2;
                }
                return ck1Var;
            }
            if (i != 1) {
                if (i != 2) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                it = (Iterator) this.b;
                baseContentViewModel2 = (BaseContentViewModel) this.a;
                s38.b(obj);
                while (it.hasNext()) {
                    hl4 hl4Var = (hl4) it.next();
                    int i2 = hl4Var.a;
                    gf1 gf1Var = (gf1) hl4Var.b;
                    if (n89.l(gf1Var.c, "continue_watching", false)) {
                        this.a = baseContentViewModel2;
                        this.b = it;
                        this.c = 2;
                        baseContentViewModel2.getClass();
                        if (BaseContentViewModel.j(baseContentViewModel2, i2, gf1Var, false, this) == ck1Var) {
                            return ck1Var;
                        }
                    }
                }
                return e6a.a;
            }
            baseContentViewModel = (BaseContentViewModel) this.b;
            mg6Var = (mg6) this.a;
            s38.b(obj);
            List listBo = y41.bo(y41.bs(y41.bo(baseContentViewModel.i)));
            mg6Var.c(null);
            it = listBo.iterator();
            while (it.hasNext()) {
            }
            return e6a.a;
        } catch (Throwable th) {
            mg6Var.c(null);
            throw th;
        }
    }
}