34 lines
841 B
Java
34 lines
841 B
Java
|
package o;
|
||
|
|
|
||
|
|
import java.util.concurrent.Callable;
|
||
|
|
|
||
|
|
/* renamed from: o.fUl, reason: case insensitive filesystem */
|
||
|
|
/* loaded from: classes6.dex */
|
||
|
|
public final class C13233fUl extends fRY {
|
||
|
|
private Callable<?> e;
|
||
|
|
|
||
|
|
public C13233fUl(Callable<?> callable) {
|
||
|
|
this.e = callable;
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // o.fRY
|
||
|
|
public final void c(InterfaceC13154fSb interfaceC13154fSb) {
|
||
|
|
fSJ j = fSJ.j();
|
||
|
|
interfaceC13154fSb.onSubscribe(j);
|
||
|
|
try {
|
||
|
|
this.e.call();
|
||
|
|
if (j.isDisposed()) {
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
interfaceC13154fSb.onComplete();
|
||
|
|
} catch (Throwable th) {
|
||
|
|
C13147fSI.c(th);
|
||
|
|
if (!j.isDisposed()) {
|
||
|
|
interfaceC13154fSb.onError(th);
|
||
|
|
} else {
|
||
|
|
C13418fZu.c(th);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|