package p000.p001.p021.p022;

import androidx.lifecycle.LiveData;
import p025.p026.AbstractC1301;
import p025.p026.C1322;
import p025.p026.C1356;
import p025.p026.EnumC1328;
import p025.p026.p029.C1405;
import p025.p026.p029.C1412;
import p025.p026.p029.C1414;
import p025.p026.p029.InterfaceC1419;
import p037.p099.C2226;
import p037.p099.InterfaceC2230;
import p138.p176.p177.p242.p246.p251.C4303;
import p402.InterfaceC6538;
import p402.InterfaceC6540;
import p402.p405.C6583;
import p402.p405.InterfaceC6578;
import p402.p411.p412.InterfaceC6603;
import p402.p411.p413.AbstractC6636;
import p402.p411.p413.C6635;

/* JADX INFO: renamed from: ނ.֏.ؠ.֏.ދ, reason: contains not printable characters */
/* JADX INFO: loaded from: classes.dex */
@InterfaceC6540
public final class C1240<T> extends C2226<T> {

    /* JADX INFO: renamed from: މ, reason: contains not printable characters */
    public final LiveData<T> f4348;

    /* JADX INFO: renamed from: ނ.֏.ؠ.֏.ދ$֏, reason: contains not printable characters */
    @InterfaceC6540
    public static final class C1241 implements InterfaceC2230<T> {

        /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
        public boolean f4349;

        /* JADX INFO: renamed from: ؠ, reason: contains not printable characters */
        public T f4350;

        /* JADX INFO: renamed from: ހ, reason: contains not printable characters */
        public final InterfaceC6538 f4351 = C4303.m7065((InterfaceC6603) new C1242());

        /* JADX INFO: renamed from: ނ.֏.ؠ.֏.ދ$֏$֏, reason: contains not printable characters */
        public static final class C1242 extends AbstractC6636 implements InterfaceC6603<InterfaceC1419<? super T>> {
            public C1242() {
                super(0);
            }

            @Override // p402.p411.p412.InterfaceC6603
            /* JADX INFO: renamed from: ނ */
            public Object mo1543() {
                C1356 c1356 = C1356.f4507;
                C1239 c1239 = new C1239(this, null);
                C6583 c6583 = C6583.f19356;
                EnumC1328 enumC1328 = EnumC1328.DEFAULT;
                InterfaceC6578 interfaceC6578M2649 = C1322.m2649(c1356, c6583);
                C1412 c1412 = new C1412();
                AbstractC1301 c1414 = enumC1328.m2654() ? new C1414(interfaceC6578M2649, c1412, c1239) : new C1405(interfaceC6578M2649, c1412, true);
                c1414.m2609(enumC1328, c1414, c1239);
                return c1414;
            }
        }

        public C1241() {
        }

        @Override // p037.p099.InterfaceC2230
        /* JADX INFO: renamed from: ֏ */
        public void mo1576(T t) {
            if (this.f4349) {
                ((InterfaceC1419) this.f4351.getValue()).offer(t);
                return;
            }
            this.f4349 = true;
            this.f4350 = t;
            C1240.this.mo345(t);
        }
    }

    /* JADX WARN: Multi-variable type inference failed */
    public C1240(LiveData<T> liveData) {
        if (liveData == 0) {
            C6635.m9824("sourceLiveData");
            throw null;
        }
        this.f4348 = liveData;
        m4290(liveData, new C1241());
    }
}