36 lines
1.4 KiB
Java
36 lines
1.4 KiB
Java
package io.reactivex.internal.operators.observable;
|
|
|
|
import io.reactivex.ObservableOperator;
|
|
import io.reactivex.ObservableSource;
|
|
import io.reactivex.Observer;
|
|
import io.reactivex.exceptions.Exceptions;
|
|
import io.reactivex.internal.functions.ObjectHelper;
|
|
import io.reactivex.plugins.RxJavaPlugins;
|
|
|
|
/* loaded from: classes2.dex */
|
|
public final class ObservableLift<R, T> extends AbstractObservableWithUpstream<T, R> {
|
|
final ObservableOperator<? extends R, ? super T> b;
|
|
|
|
public ObservableLift(ObservableSource<T> observableSource, ObservableOperator<? extends R, ? super T> observableOperator) {
|
|
super(observableSource);
|
|
this.b = observableOperator;
|
|
}
|
|
|
|
@Override // io.reactivex.Observable
|
|
public void subscribeActual(Observer<? super R> observer) {
|
|
try {
|
|
Observer<? super Object> a = this.b.a(observer);
|
|
ObjectHelper.a(a, "Operator " + this.b + " returned a null Observer");
|
|
this.a.subscribe(a);
|
|
} catch (NullPointerException e) {
|
|
throw e;
|
|
} catch (Throwable th) {
|
|
Exceptions.b(th);
|
|
RxJavaPlugins.b(th);
|
|
NullPointerException nullPointerException = new NullPointerException("Actually not, but can't throw other exceptions due to RS");
|
|
nullPointerException.initCause(th);
|
|
throw nullPointerException;
|
|
}
|
|
}
|
|
}
|