40 lines
1.6 KiB
Java
40 lines
1.6 KiB
Java
|
package o;
|
||
|
|
|
||
|
|
import java.util.Objects;
|
||
|
|
|
||
|
|
/* renamed from: o.fSg, reason: case insensitive filesystem */
|
||
|
|
/* loaded from: classes.dex */
|
||
|
|
public abstract class AbstractC13159fSg<T> implements InterfaceC13160fSh<T> {
|
||
|
|
protected abstract void a(InterfaceC13161fSi<? super T> interfaceC13161fSi);
|
||
|
|
|
||
|
|
public static <T> AbstractC13159fSg<T> b(InterfaceC13160fSh<T> interfaceC13160fSh) {
|
||
|
|
if (interfaceC13160fSh instanceof AbstractC13159fSg) {
|
||
|
|
return (AbstractC13159fSg) interfaceC13160fSh;
|
||
|
|
}
|
||
|
|
Objects.requireNonNull(interfaceC13160fSh, "source is null");
|
||
|
|
return new fUM(interfaceC13160fSh);
|
||
|
|
}
|
||
|
|
|
||
|
|
public final T a() {
|
||
|
|
fTM ftm = new fTM();
|
||
|
|
c(ftm);
|
||
|
|
return (T) ftm.d();
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // o.InterfaceC13160fSh
|
||
|
|
public final void c(InterfaceC13161fSi<? super T> interfaceC13161fSi) {
|
||
|
|
Objects.requireNonNull(interfaceC13161fSi, "observer is null");
|
||
|
|
Objects.requireNonNull(interfaceC13161fSi, "The RxJavaPlugins.onSubscribe hook returned a null MaybeObserver. Please check the handler provided to RxJavaPlugins.setOnMaybeSubscribe for invalid null returns. Further reading: https://github.com/ReactiveX/RxJava/wiki/Plugins");
|
||
|
|
try {
|
||
|
|
a(interfaceC13161fSi);
|
||
|
|
} catch (NullPointerException e) {
|
||
|
|
throw e;
|
||
|
|
} catch (Throwable th) {
|
||
|
|
C13147fSI.c(th);
|
||
|
|
NullPointerException nullPointerException = new NullPointerException("subscribeActual failed");
|
||
|
|
nullPointerException.initCause(th);
|
||
|
|
throw nullPointerException;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|