69 lines
2.1 KiB
Java
69 lines
2.1 KiB
Java
|
package o;
|
||
|
|
|
||
|
|
import o.GJE;
|
||
|
|
|
||
|
|
/* loaded from: classes3.dex */
|
||
|
|
public final class OQD extends wRi {
|
||
|
|
final InterfaceC0773Ogw e;
|
||
|
|
|
||
|
|
/* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
|
||
|
|
@InterfaceC13391fZD
|
||
|
|
public OQD(yRw yrw, yRw yrw2, InterfaceC0773Ogw interfaceC0773Ogw) {
|
||
|
|
super(yrw, yrw2);
|
||
|
|
C14957gcv.e(yrw, "");
|
||
|
|
C14957gcv.e(yrw2, "");
|
||
|
|
C14957gcv.e(interfaceC0773Ogw, "");
|
||
|
|
this.e = interfaceC0773Ogw;
|
||
|
|
}
|
||
|
|
|
||
|
|
/* JADX INFO: Access modifiers changed from: package-private */
|
||
|
|
/* loaded from: classes3.dex */
|
||
|
|
public static final class HBt extends AbstractC14961gcz implements InterfaceC14894gbR<Bpv, C14866gag> {
|
||
|
|
private OQD b;
|
||
|
|
|
||
|
|
@Override // o.InterfaceC14894gbR
|
||
|
|
public final /* synthetic */ C14866gag invoke(Bpv bpv) {
|
||
|
|
GJE gje;
|
||
|
|
GJE gje2;
|
||
|
|
Bpv bpv2 = bpv;
|
||
|
|
if (bpv2 != null && (gje2 = bpv2.j) != null) {
|
||
|
|
this.b.e.a(gje2, GJE.Sts.HOME);
|
||
|
|
C14866gag c14866gag = C14866gag.c;
|
||
|
|
}
|
||
|
|
OQD oqd = this.b;
|
||
|
|
if (bpv2 != null && (gje = bpv2.h) != null) {
|
||
|
|
oqd.e.a(gje, GJE.Sts.MAILING);
|
||
|
|
}
|
||
|
|
return C14866gag.c;
|
||
|
|
}
|
||
|
|
|
||
|
|
/* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
|
||
|
|
HBt(OQD oqd) {
|
||
|
|
super(1);
|
||
|
|
this.b = oqd;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
public final AbstractC13163fSk<Bpv> e() {
|
||
|
|
AbstractC13163fSk<Bpv> D = this.e.D();
|
||
|
|
final HBt hBt = new HBt(this);
|
||
|
|
AbstractC13163fSk<Bpv> doOnNext = D.doOnNext(new fSQ(hBt) { // from class: o.IWX
|
||
|
|
private InterfaceC14894gbR e;
|
||
|
|
|
||
|
|
@Override // o.fSQ
|
||
|
|
public final void c(Object obj) {
|
||
|
|
InterfaceC14894gbR interfaceC14894gbR = this.e;
|
||
|
|
C14957gcv.e(interfaceC14894gbR, "");
|
||
|
|
interfaceC14894gbR.invoke(obj);
|
||
|
|
}
|
||
|
|
|
||
|
|
{
|
||
|
|
this.e = hBt;
|
||
|
|
}
|
||
|
|
});
|
||
|
|
e(doOnNext);
|
||
|
|
C14957gcv.c(doOnNext, "");
|
||
|
|
return doOnNext;
|
||
|
|
}
|
||
|
|
}
|