39 lines
1.2 KiB
Java
39 lines
1.2 KiB
Java
|
package o;
|
||
|
|
|
||
|
|
import java.util.concurrent.Callable;
|
||
|
|
|
||
|
|
/* renamed from: o.fWb, reason: case insensitive filesystem */
|
||
|
|
/* loaded from: classes6.dex */
|
||
|
|
public final class C13293fWb<T> extends AbstractC13163fSk<T> implements InterfaceC13189fTc<T> {
|
||
|
|
private Callable<? extends T> d;
|
||
|
|
|
||
|
|
public C13293fWb(Callable<? extends T> callable) {
|
||
|
|
this.d = callable;
|
||
|
|
}
|
||
|
|
|
||
|
|
/* 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.d.call(), "Callable 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.d.call(), "The Callable returned a null value.");
|
||
|
|
}
|
||
|
|
}
|