105 lines
2.8 KiB
Java
105 lines
2.8 KiB
Java
package o;
|
|
|
|
import java.util.List;
|
|
import java.util.Objects;
|
|
import o.InterfaceC6669cZl;
|
|
import o.ZI;
|
|
import o.bEI;
|
|
import o.wRi;
|
|
|
|
/* loaded from: classes4.dex */
|
|
public class bEI extends ZI<InterfaceC6669cZl.RVV> {
|
|
private List<PS> a;
|
|
private final C17340vt b;
|
|
public final C17752zVW d;
|
|
|
|
@InterfaceC13391fZD
|
|
public bEI(C16903sI c16903sI, C17752zVW c17752zVW, C17340vt c17340vt) {
|
|
super(c16903sI);
|
|
this.b = c17340vt;
|
|
this.d = c17752zVW;
|
|
}
|
|
|
|
/* loaded from: classes4.dex */
|
|
public class Sts extends wRi.LWm<List<Gbo>> {
|
|
private bEI e;
|
|
|
|
public Sts(bEI bei) {
|
|
this.e = bei;
|
|
}
|
|
|
|
@Override // o.wRi.LWm, o.InterfaceC13174fSv
|
|
public final /* synthetic */ void onNext(Object obj) {
|
|
List list = (List) obj;
|
|
bEI.e(this.e);
|
|
if (list != null) {
|
|
bEI bei = this.e;
|
|
C17340vt unused = bei.b;
|
|
final C17340vt c17340vt = this.e.b;
|
|
Objects.requireNonNull(c17340vt);
|
|
bei.a = (List) C16157lj.c(new Object[]{list, new InterfaceC1244Ytw(c17340vt) { // from class: o.bEH
|
|
private C17340vt a;
|
|
|
|
@Override // o.InterfaceC1244Ytw
|
|
public final Object d(Object obj2) {
|
|
return C17340vt.c((Gbo) obj2);
|
|
}
|
|
|
|
{
|
|
this.a = c17340vt;
|
|
}
|
|
}}, -1846295624, 1846295631, (int) System.currentTimeMillis());
|
|
bEI bei2 = this.e;
|
|
ZI.IeS ieS = new ZI.IeS(this) { // from class: o.bEL
|
|
private bEI.Sts d;
|
|
|
|
@Override // o.ZI.IeS
|
|
public final void e(Object obj2) {
|
|
((InterfaceC6669cZl.RVV) obj2).e(this.d.e.a);
|
|
}
|
|
|
|
{
|
|
this.d = this;
|
|
}
|
|
};
|
|
if (bei2.f != 0) {
|
|
ieS.e(bei2.f);
|
|
}
|
|
}
|
|
}
|
|
|
|
@Override // o.wRi.LWm, o.InterfaceC13174fSv
|
|
public final void onError(Throwable th) {
|
|
bEI.c(this.e);
|
|
bEI.d(this.e, th);
|
|
}
|
|
}
|
|
|
|
static /* synthetic */ void c(bEI bei) {
|
|
if (bei.f != 0) {
|
|
bei.f.ar_();
|
|
}
|
|
}
|
|
|
|
static /* synthetic */ void d(bEI bei, Throwable th) {
|
|
if (bei.b(th)) {
|
|
bei.d(bei.j.e(th));
|
|
}
|
|
}
|
|
|
|
static /* synthetic */ void e(bEI bei) {
|
|
if (bei.f != 0) {
|
|
bei.f.ar_();
|
|
}
|
|
}
|
|
|
|
@Override // o.ZI
|
|
public final void w_() {
|
|
C17752zVW c17752zVW = this.d;
|
|
if (!c17752zVW.h.isDisposed()) {
|
|
c17752zVW.h.dispose();
|
|
}
|
|
super.w_();
|
|
}
|
|
}
|