120 lines
3.6 KiB
Java
120 lines
3.6 KiB
Java
|
package o;
|
||
|
|
||
|
import com.scb.phone.data.entity.transfer.SingleDataEntity;
|
||
|
import org.threeten.bp.OffsetDateTime;
|
||
|
|
||
|
/* renamed from: o.eKR, reason: case insensitive filesystem */
|
||
|
/* loaded from: classes3.dex */
|
||
|
public final class C10643eKR implements Swt {
|
||
|
private final Evi a;
|
||
|
final C17619yNh b;
|
||
|
final rYS c;
|
||
|
final C0196Bbq e;
|
||
|
|
||
|
@InterfaceC13391fZD
|
||
|
public C10643eKR(Evi evi, rYS rys, C17619yNh c17619yNh, C0196Bbq c0196Bbq) {
|
||
|
this.a = evi;
|
||
|
this.c = rys;
|
||
|
this.b = c17619yNh;
|
||
|
this.e = c0196Bbq;
|
||
|
}
|
||
|
|
||
|
@Override // o.Swt
|
||
|
public final int c() {
|
||
|
rYS rys = this.c;
|
||
|
SingleDataEntity<CHt> singleDataEntity = rys.e;
|
||
|
if (singleDataEntity == null || singleDataEntity.getData() == null) {
|
||
|
return 1;
|
||
|
}
|
||
|
return rys.e.getData().b;
|
||
|
}
|
||
|
|
||
|
@Override // o.Swt
|
||
|
public final AbstractC13163fSk d(C15316gnF c15316gnF) {
|
||
|
return this.a.b.getUnsubcribeRequest(c15316gnF).flatMap(new fSS() { // from class: o.qyD
|
||
|
@Override // o.fSS
|
||
|
public final Object a(Object obj) {
|
||
|
return AbstractC13163fSk.just(Boolean.TRUE);
|
||
|
}
|
||
|
});
|
||
|
}
|
||
|
|
||
|
@Override // o.Swt
|
||
|
public final AbstractC13163fSk<XUx> d(C15949jrV c15949jrV) {
|
||
|
return this.a.b.getConfirmRequest(c15949jrV).flatMap(new fSS(this) { // from class: o.eaq
|
||
|
private C10643eKR a;
|
||
|
|
||
|
@Override // o.fSS
|
||
|
public final Object a(Object obj) {
|
||
|
C0196Bbq c0196Bbq = this.a.e;
|
||
|
YDb yDb = (YDb) ((SingleDataEntity) obj).getData();
|
||
|
XUx b = XUx.b();
|
||
|
b.a = yDb.e;
|
||
|
b.b = (OffsetDateTime) ZTC.e(new Object[]{yDb.a, null}, 267499366, -267499366, (int) System.currentTimeMillis());
|
||
|
return AbstractC13163fSk.just(b);
|
||
|
}
|
||
|
|
||
|
{
|
||
|
this.a = this;
|
||
|
}
|
||
|
});
|
||
|
}
|
||
|
|
||
|
@Override // o.Swt
|
||
|
public final AbstractC13163fSk<GvC> a(final int i) {
|
||
|
if (this.c.d < i) {
|
||
|
return this.a.b.getEBillSubscription(i).doOnNext(new fSQ(this, i) { // from class: o.MmE
|
||
|
private int a;
|
||
|
private C10643eKR b;
|
||
|
|
||
|
@Override // o.fSQ
|
||
|
public final void c(Object obj) {
|
||
|
C10643eKR c10643eKR = this.b;
|
||
|
int i2 = this.a;
|
||
|
SingleDataEntity<CHt> singleDataEntity = (SingleDataEntity) obj;
|
||
|
rYS rys = c10643eKR.c;
|
||
|
if (rys.e == null) {
|
||
|
rys.e = singleDataEntity;
|
||
|
}
|
||
|
rys.d = i2;
|
||
|
}
|
||
|
|
||
|
{
|
||
|
this.b = this;
|
||
|
this.a = i;
|
||
|
}
|
||
|
}).flatMap(new fSS(this) { // from class: o.Bay
|
||
|
private C10643eKR d;
|
||
|
|
||
|
@Override // o.fSS
|
||
|
public final Object a(Object obj) {
|
||
|
C17619yNh c17619yNh = this.d.b;
|
||
|
return AbstractC13163fSk.just(C17619yNh.c((SingleDataEntity<CHt>) obj));
|
||
|
}
|
||
|
|
||
|
{
|
||
|
this.d = this;
|
||
|
}
|
||
|
});
|
||
|
}
|
||
|
return AbstractC13163fSk.just(C17619yNh.c(this.c.e));
|
||
|
}
|
||
|
|
||
|
@Override // o.Swt
|
||
|
public final AbstractC13163fSk<GvC> a() {
|
||
|
return AbstractC13163fSk.just(C17619yNh.c(this.c.e));
|
||
|
}
|
||
|
|
||
|
@Override // o.Swt
|
||
|
public final int e() {
|
||
|
return this.c.d;
|
||
|
}
|
||
|
|
||
|
@Override // o.QpH
|
||
|
public final void f() {
|
||
|
rYS rys = this.c;
|
||
|
rys.d = 0;
|
||
|
rys.e = null;
|
||
|
}
|
||
|
}
|