134 lines
3.9 KiB
Java
134 lines
3.9 KiB
Java
|
package o;
|
||
|
|
||
|
import java.util.List;
|
||
|
import o.C0690Mh;
|
||
|
import o.C2677ajC;
|
||
|
import o.InterfaceC6636cYn;
|
||
|
import o.ZI;
|
||
|
import o.wRi;
|
||
|
|
||
|
/* renamed from: o.ajC, reason: case insensitive filesystem */
|
||
|
/* loaded from: classes3.dex */
|
||
|
public class C2677ajC extends ZI<InterfaceC6636cYn.RVV> {
|
||
|
private final C17361wD a;
|
||
|
public C1236Yq c;
|
||
|
public final iNh d;
|
||
|
|
||
|
@InterfaceC13391fZD
|
||
|
public C2677ajC(C16903sI c16903sI, C17361wD c17361wD, iNh inh) {
|
||
|
super(c16903sI);
|
||
|
this.d = inh;
|
||
|
this.a = c17361wD;
|
||
|
}
|
||
|
|
||
|
/* renamed from: o.ajC$HBt */
|
||
|
/* loaded from: classes3.dex */
|
||
|
public final class HBt extends wRi.LWm<List<C16588pYG>> {
|
||
|
private C2677ajC b;
|
||
|
|
||
|
private HBt(C2677ajC c2677ajC) {
|
||
|
this.b = c2677ajC;
|
||
|
}
|
||
|
|
||
|
@Override // o.wRi.LWm, o.InterfaceC13174fSv
|
||
|
public final /* synthetic */ void onNext(Object obj) {
|
||
|
final List list = (List) obj;
|
||
|
C2677ajC c2677ajC = this.b;
|
||
|
C2680ajF c2680ajF = new C2680ajF();
|
||
|
if (c2677ajC.f != 0) {
|
||
|
c2680ajF.e(c2677ajC.f);
|
||
|
}
|
||
|
C2677ajC c2677ajC2 = this.b;
|
||
|
ZI.IeS ieS = new ZI.IeS(this, list) { // from class: o.ajM
|
||
|
private C2677ajC.HBt d;
|
||
|
private List e;
|
||
|
|
||
|
@Override // o.ZI.IeS
|
||
|
public final void e(Object obj2) {
|
||
|
C2677ajC.HBt.c(this.d, this.e, (InterfaceC6636cYn.RVV) obj2);
|
||
|
}
|
||
|
|
||
|
{
|
||
|
this.d = this;
|
||
|
this.e = list;
|
||
|
}
|
||
|
};
|
||
|
if (c2677ajC2.f != 0) {
|
||
|
ieS.e(c2677ajC2.f);
|
||
|
}
|
||
|
}
|
||
|
|
||
|
@Override // o.wRi.LWm, o.InterfaceC13174fSv
|
||
|
public final void onError(Throwable th) {
|
||
|
C2677ajC c2677ajC = this.b;
|
||
|
C2680ajF c2680ajF = new C2680ajF();
|
||
|
if (c2677ajC.f != 0) {
|
||
|
c2680ajF.e(c2677ajC.f);
|
||
|
}
|
||
|
C2677ajC c2677ajC2 = this.b;
|
||
|
ZI.IeS ieS = new ZI.IeS() { // from class: o.ajH
|
||
|
@Override // o.ZI.IeS
|
||
|
public final void e(Object obj) {
|
||
|
((InterfaceC6636cYn.RVV) obj).a();
|
||
|
}
|
||
|
};
|
||
|
if (c2677ajC2.f != 0) {
|
||
|
ieS.e(c2677ajC2.f);
|
||
|
}
|
||
|
}
|
||
|
|
||
|
public static /* synthetic */ void c(HBt hBt, List list, InterfaceC6636cYn.RVV rvv) {
|
||
|
C17361wD unused = hBt.b.a;
|
||
|
rvv.a(C17361wD.d((List<C16588pYG>) list));
|
||
|
}
|
||
|
|
||
|
public /* synthetic */ HBt(C2677ajC c2677ajC, byte b) {
|
||
|
this(c2677ajC);
|
||
|
}
|
||
|
}
|
||
|
|
||
|
/* renamed from: o.ajC$IeS */
|
||
|
/* loaded from: classes3.dex */
|
||
|
public final class IeS extends wRi.LWm<Boolean> {
|
||
|
private C2677ajC e;
|
||
|
|
||
|
private IeS(C2677ajC c2677ajC) {
|
||
|
this.e = c2677ajC;
|
||
|
}
|
||
|
|
||
|
@Override // o.wRi.LWm, o.InterfaceC13174fSv
|
||
|
public final /* synthetic */ void onNext(Object obj) {
|
||
|
C2677ajC.b(this.e);
|
||
|
C2677ajC c2677ajC = this.e;
|
||
|
ZI.IeS ieS = new ZI.IeS() { // from class: o.ajG
|
||
|
@Override // o.ZI.IeS
|
||
|
public final void e(Object obj2) {
|
||
|
((InterfaceC6636cYn.RVV) obj2).c();
|
||
|
}
|
||
|
};
|
||
|
if (c2677ajC.f != 0) {
|
||
|
ieS.e(c2677ajC.f);
|
||
|
}
|
||
|
}
|
||
|
|
||
|
@Override // o.wRi.LWm, o.InterfaceC13174fSv
|
||
|
public final void onError(Throwable th) {
|
||
|
C2677ajC c2677ajC = this.e;
|
||
|
C0690Mh.IeS ieS = C0690Mh.IeS.JUST_DISMISS;
|
||
|
if (c2677ajC.b(th)) {
|
||
|
c2677ajC.d(c2677ajC.j.b(th, ieS));
|
||
|
}
|
||
|
}
|
||
|
|
||
|
public /* synthetic */ IeS(C2677ajC c2677ajC, byte b) {
|
||
|
this(c2677ajC);
|
||
|
}
|
||
|
}
|
||
|
|
||
|
static /* synthetic */ void b(C2677ajC c2677ajC) {
|
||
|
if (c2677ajC.f != 0) {
|
||
|
c2677ajC.f.ar_();
|
||
|
}
|
||
|
}
|
||
|
}
|