128 lines
3.8 KiB
Java
128 lines
3.8 KiB
Java
package o;
|
|
|
|
import java.util.Collection;
|
|
import java.util.Iterator;
|
|
import java.util.List;
|
|
import o.wRi;
|
|
|
|
/* renamed from: o.hJ, reason: case insensitive filesystem */
|
|
/* loaded from: classes3.dex */
|
|
public final class C15628hJ extends C15620hF {
|
|
private final REU b;
|
|
InterfaceC14894gbR<? super FF, C14866gag> c;
|
|
public final InterfaceC3521azC d;
|
|
InterfaceC14894gbR<? super Throwable, C14866gag> e;
|
|
|
|
/* renamed from: o.hJ$LWm */
|
|
/* loaded from: classes3.dex */
|
|
public static final class LWm {
|
|
private LWm() {
|
|
}
|
|
|
|
public /* synthetic */ LWm(byte b) {
|
|
this();
|
|
}
|
|
}
|
|
|
|
/* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
|
|
@InterfaceC13391fZD
|
|
public C15628hJ(InterfaceC3521azC interfaceC3521azC, REU reu) {
|
|
super((byte) 0);
|
|
C14957gcv.e(interfaceC3521azC, "");
|
|
C14957gcv.e(reu, "");
|
|
this.d = interfaceC3521azC;
|
|
this.b = reu;
|
|
this.c = HBt.b;
|
|
this.e = Sts.c;
|
|
}
|
|
|
|
/* renamed from: o.hJ$HBt */
|
|
/* loaded from: classes3.dex */
|
|
static final class HBt extends AbstractC14961gcz implements InterfaceC14894gbR<FF, C14866gag> {
|
|
public static final HBt b = new HBt();
|
|
|
|
@Override // o.InterfaceC14894gbR
|
|
public final /* synthetic */ C14866gag invoke(FF ff) {
|
|
C14957gcv.e(ff, "");
|
|
return C14866gag.c;
|
|
}
|
|
|
|
HBt() {
|
|
super(1);
|
|
}
|
|
}
|
|
|
|
/* renamed from: o.hJ$Sts */
|
|
/* loaded from: classes3.dex */
|
|
static final class Sts extends AbstractC14961gcz implements InterfaceC14894gbR<Throwable, C14866gag> {
|
|
public static final Sts c = new Sts();
|
|
|
|
@Override // o.InterfaceC14894gbR
|
|
public final /* synthetic */ C14866gag invoke(Throwable th) {
|
|
C14957gcv.e(th, "");
|
|
return C14866gag.c;
|
|
}
|
|
|
|
Sts() {
|
|
super(1);
|
|
}
|
|
}
|
|
|
|
public final void d(InterfaceC14894gbR<? super FF, C14866gag> interfaceC14894gbR, InterfaceC14894gbR<? super Throwable, C14866gag> interfaceC14894gbR2) {
|
|
C14957gcv.e(interfaceC14894gbR, "");
|
|
C14957gcv.e(interfaceC14894gbR2, "");
|
|
this.c = interfaceC14894gbR;
|
|
this.e = interfaceC14894gbR2;
|
|
this.b.d();
|
|
REU reu = this.b;
|
|
reu.d(reu.i, new IeS(this));
|
|
}
|
|
|
|
/* JADX INFO: Access modifiers changed from: package-private */
|
|
/* renamed from: o.hJ$IeS */
|
|
/* loaded from: classes3.dex */
|
|
public final class IeS extends wRi.LWm<jJR> {
|
|
private C15628hJ e;
|
|
|
|
@Override // o.wRi.LWm, o.InterfaceC13174fSv
|
|
public final /* synthetic */ void onNext(Object obj) {
|
|
boolean z;
|
|
jJR jjr = (jJR) obj;
|
|
C14957gcv.e(jjr, "");
|
|
super.onNext(jjr);
|
|
if (!(!jjr.e.isEmpty())) {
|
|
this.e.c.invoke(new FF(false, false, "", "", ""));
|
|
return;
|
|
}
|
|
List<IDx> list = jjr.e;
|
|
if (!(list instanceof Collection) || !list.isEmpty()) {
|
|
Iterator<T> it = list.iterator();
|
|
while (it.hasNext()) {
|
|
if (!(!((IDx) it.next()).c)) {
|
|
z = false;
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
z = true;
|
|
boolean z2 = !z;
|
|
this.e.c.invoke(new FF(z2, !jjr.b.e && z2, jjr.b.c, jjr.b.d, ((IDx) C14881gav.e((List) jjr.e)).b));
|
|
}
|
|
|
|
public IeS(C15628hJ c15628hJ) {
|
|
this.e = c15628hJ;
|
|
}
|
|
|
|
@Override // o.wRi.LWm, o.InterfaceC13174fSv
|
|
public final void onError(Throwable th) {
|
|
C14957gcv.e(th, "");
|
|
super.onError(th);
|
|
this.e.e.invoke(th);
|
|
}
|
|
}
|
|
|
|
static {
|
|
new LWm((byte) 0);
|
|
}
|
|
}
|