75 lines
2.1 KiB
Java
75 lines
2.1 KiB
Java
|
package o;
|
||
|
|
|
||
|
|
import java.util.Objects;
|
||
|
|
import java.util.concurrent.atomic.AtomicReference;
|
||
|
|
|
||
|
|
/* renamed from: o.fYb, reason: case insensitive filesystem */
|
||
|
|
/* loaded from: classes6.dex */
|
||
|
|
public final class C13363fYb<T> extends fRY {
|
||
|
|
private fSD<T> d;
|
||
|
|
private fSS<? super T, ? extends fRZ> e;
|
||
|
|
|
||
|
|
public C13363fYb(fSD<T> fsd, fSS<? super T, ? extends fRZ> fss) {
|
||
|
|
this.d = fsd;
|
||
|
|
this.e = fss;
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // o.fRY
|
||
|
|
public final void c(InterfaceC13154fSb interfaceC13154fSb) {
|
||
|
|
RVV rvv = new RVV(interfaceC13154fSb, this.e);
|
||
|
|
interfaceC13154fSb.onSubscribe(rvv);
|
||
|
|
this.d.c(rvv);
|
||
|
|
}
|
||
|
|
|
||
|
|
/* renamed from: o.fYb$RVV */
|
||
|
|
/* loaded from: classes6.dex */
|
||
|
|
static final class RVV<T> extends AtomicReference<fSJ> implements InterfaceC13176fSx<T>, InterfaceC13154fSb, fSJ {
|
||
|
|
private fSS<? super T, ? extends fRZ> c;
|
||
|
|
private InterfaceC13154fSb d;
|
||
|
|
|
||
|
|
RVV(InterfaceC13154fSb interfaceC13154fSb, fSS<? super T, ? extends fRZ> fss) {
|
||
|
|
this.d = interfaceC13154fSb;
|
||
|
|
this.c = fss;
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // o.fSJ
|
||
|
|
public final void dispose() {
|
||
|
|
EnumC13192fTf.e(this);
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // o.fSJ
|
||
|
|
public final boolean isDisposed() {
|
||
|
|
return EnumC13192fTf.c(get());
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // o.InterfaceC13176fSx
|
||
|
|
public final void onSubscribe(fSJ fsj) {
|
||
|
|
EnumC13192fTf.c(this, fsj);
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // o.InterfaceC13176fSx
|
||
|
|
public final void e(T t) {
|
||
|
|
try {
|
||
|
|
fRZ frz = (fRZ) Objects.requireNonNull(this.c.a(t), "The mapper returned a null CompletableSource");
|
||
|
|
if (isDisposed()) {
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
frz.e(this);
|
||
|
|
} catch (Throwable th) {
|
||
|
|
C13147fSI.c(th);
|
||
|
|
onError(th);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // o.InterfaceC13176fSx
|
||
|
|
public final void onError(Throwable th) {
|
||
|
|
this.d.onError(th);
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // o.InterfaceC13154fSb
|
||
|
|
public final void onComplete() {
|
||
|
|
this.d.onComplete();
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|