37 lines
1.2 KiB
Java
37 lines
1.2 KiB
Java
|
package o;
|
||
|
|
|
||
|
|
/* renamed from: o.fWh, reason: case insensitive filesystem */
|
||
|
|
/* loaded from: classes6.dex */
|
||
|
|
public final class C13299fWh<T> extends AbstractC13163fSk<T> implements InterfaceC13189fTc<T> {
|
||
|
|
private InterfaceC13189fTc<? extends T> a;
|
||
|
|
|
||
|
|
public C13299fWh(InterfaceC13189fTc<? extends T> interfaceC13189fTc) {
|
||
|
|
this.a = interfaceC13189fTc;
|
||
|
|
}
|
||
|
|
|
||
|
|
/* JADX WARN: Multi-variable type inference failed */
|
||
|
|
@Override // o.AbstractC13163fSk
|
||
|
|
public final void subscribeActual(InterfaceC13174fSv<? super T> interfaceC13174fSv) {
|
||
|
|
fTO fto = new fTO(interfaceC13174fSv);
|
||
|
|
interfaceC13174fSv.onSubscribe(fto);
|
||
|
|
if (fto.isDisposed()) {
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
try {
|
||
|
|
fto.d(fYR.d(this.a.d(), "Supplier returned a null value."));
|
||
|
|
} catch (Throwable th) {
|
||
|
|
C13147fSI.c(th);
|
||
|
|
if (!fto.isDisposed()) {
|
||
|
|
interfaceC13174fSv.onError(th);
|
||
|
|
} else {
|
||
|
|
C13418fZu.c(th);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // o.InterfaceC13189fTc
|
||
|
|
public final T d() throws Throwable {
|
||
|
|
return (T) fYR.d(this.a.d(), "The supplier returned a null value.");
|
||
|
|
}
|
||
|
|
}
|