128 lines
3.8 KiB
Java
128 lines
3.8 KiB
Java
package o;
|
|
|
|
import com.scb.phone.data.entity.transfer.SingleDataEntity;
|
|
import java.util.ArrayList;
|
|
import java.util.Collection;
|
|
import java.util.Iterator;
|
|
import java.util.List;
|
|
import java.util.Objects;
|
|
|
|
/* loaded from: classes3.dex */
|
|
public final class nsT implements InterfaceC2070aWe {
|
|
private final gDK a;
|
|
private final Hfm b;
|
|
private final DDE c;
|
|
private final tRa d;
|
|
final UAu e;
|
|
|
|
@InterfaceC13391fZD
|
|
public nsT(DDE dde, UAu uAu, Hfm hfm, tRa tra, gDK gdk) {
|
|
this.c = dde;
|
|
this.e = uAu;
|
|
this.b = hfm;
|
|
this.d = tra;
|
|
this.a = gdk;
|
|
}
|
|
|
|
@Override // o.InterfaceC2070aWe
|
|
public final AbstractC13163fSk<HCR> a() {
|
|
return this.c.d.getNotifications().map(new fSS(this) { // from class: o.auv
|
|
private nsT d;
|
|
|
|
@Override // o.fSS
|
|
public final Object a(Object obj) {
|
|
return this.d.e.c((C3606bBK) ((SingleDataEntity) obj).getData());
|
|
}
|
|
|
|
{
|
|
this.d = this;
|
|
}
|
|
});
|
|
}
|
|
|
|
@Override // o.InterfaceC2070aWe
|
|
public final AbstractC13163fSk<HCR> a(String str) {
|
|
return this.c.d.getNotifications(str).map(new fSS(this) { // from class: o.qoU
|
|
private nsT b;
|
|
|
|
@Override // o.fSS
|
|
public final Object a(Object obj) {
|
|
return this.b.e.c((C3606bBK) ((SingleDataEntity) obj).getData());
|
|
}
|
|
|
|
{
|
|
this.b = this;
|
|
}
|
|
});
|
|
}
|
|
|
|
@Override // o.InterfaceC2070aWe
|
|
public final AbstractC13163fSk<AWC> e() {
|
|
AbstractC13163fSk<SingleDataEntity<rLP>> notificationUnreadCount = this.c.d.getNotificationUnreadCount();
|
|
final Hfm hfm = this.b;
|
|
Objects.requireNonNull(hfm);
|
|
return notificationUnreadCount.map(new fSS(hfm) { // from class: o.yOR
|
|
private Hfm d;
|
|
|
|
@Override // o.fSS
|
|
public final Object a(Object obj) {
|
|
return Hfm.d((SingleDataEntity<rLP>) obj);
|
|
}
|
|
|
|
{
|
|
this.d = hfm;
|
|
}
|
|
});
|
|
}
|
|
|
|
@Override // o.InterfaceC2070aWe
|
|
public final AbstractC13175fSw<List<XNX>> c() {
|
|
fUY fuy = new fUY(new C13372fYk(this.c.d.getNotificationPreferences().firstOrError(), new fSS() { // from class: o.NVw
|
|
@Override // o.fSS
|
|
public final Object a(Object obj) {
|
|
return ((ypB) ((SingleDataEntity) obj).getData()).e;
|
|
}
|
|
}), new fSS() { // from class: o.Hfb
|
|
@Override // o.fSS
|
|
public final Object a(Object obj) {
|
|
return AbstractC13163fSk.fromIterable((List) obj);
|
|
}
|
|
});
|
|
final tRa tra = this.d;
|
|
Objects.requireNonNull(tra);
|
|
return fuy.map(new fSS(tra) { // from class: o.JiA
|
|
private tRa e;
|
|
|
|
@Override // o.fSS
|
|
public final Object a(Object obj) {
|
|
return this.e.b((xMn) obj);
|
|
}
|
|
|
|
{
|
|
this.e = tra;
|
|
}
|
|
}).toList();
|
|
}
|
|
|
|
@Override // o.InterfaceC2070aWe
|
|
public final fRY b(List<XNX> list) {
|
|
DDE dde = this.c;
|
|
gDK gdk = this.a;
|
|
C14957gcv.e(list, "");
|
|
List<XNX> list2 = list;
|
|
mFW mfw = gdk.a;
|
|
C14957gcv.e(list2, "");
|
|
ArrayList arrayList = new ArrayList(list2 instanceof Collection ? list2.size() : 10);
|
|
Iterator<T> it = list2.iterator();
|
|
while (it.hasNext()) {
|
|
arrayList.add(mfw.a((XNX) it.next()));
|
|
}
|
|
return dde.d.updateNotificationPreferences(new ypB(arrayList)).flatMapCompletable(new fSS() { // from class: o.QKy
|
|
@Override // o.fSS
|
|
public final Object a(Object obj) {
|
|
return new wSg();
|
|
}
|
|
});
|
|
}
|
|
}
|