53 lines
1.5 KiB
Java
53 lines
1.5 KiB
Java
|
package o;
|
||
|
|
|
||
|
|
/* renamed from: o.fUu, reason: case insensitive filesystem */
|
||
|
|
/* loaded from: classes6.dex */
|
||
|
|
public final class C13242fUu<T> extends AbstractC13175fSw<T> {
|
||
|
|
final T a;
|
||
|
|
private fRZ d;
|
||
|
|
final InterfaceC13189fTc<? extends T> e = null;
|
||
|
|
|
||
|
|
public C13242fUu(fRZ frz, T t) {
|
||
|
|
this.d = frz;
|
||
|
|
this.a = t;
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // o.AbstractC13175fSw
|
||
|
|
public final void e(InterfaceC13176fSx<? super T> interfaceC13176fSx) {
|
||
|
|
this.d.e(new Sts(this, interfaceC13176fSx));
|
||
|
|
}
|
||
|
|
|
||
|
|
/* renamed from: o.fUu$Sts */
|
||
|
|
/* loaded from: classes6.dex */
|
||
|
|
final class Sts implements InterfaceC13154fSb {
|
||
|
|
private final InterfaceC13176fSx<? super T> d;
|
||
|
|
private C13242fUu e;
|
||
|
|
|
||
|
|
Sts(C13242fUu c13242fUu, InterfaceC13176fSx<? super T> interfaceC13176fSx) {
|
||
|
|
this.e = c13242fUu;
|
||
|
|
this.d = interfaceC13176fSx;
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // o.InterfaceC13154fSb
|
||
|
|
public final void onComplete() {
|
||
|
|
InterfaceC13189fTc<? extends T> interfaceC13189fTc = this.e.e;
|
||
|
|
T t = this.e.a;
|
||
|
|
if (t == null) {
|
||
|
|
this.d.onError(new NullPointerException("The value supplied is null"));
|
||
|
|
} else {
|
||
|
|
this.d.e(t);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // o.InterfaceC13154fSb
|
||
|
|
public final void onError(Throwable th) {
|
||
|
|
this.d.onError(th);
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // o.InterfaceC13154fSb
|
||
|
|
public final void onSubscribe(fSJ fsj) {
|
||
|
|
this.d.onSubscribe(fsj);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|