INNER CODE UNIT · Java
subscribe
uber/AutoDispose · autodispose/src/main/java/autodispose2/AutoDispose.java:178
public Disposable subscribe(Consumer<? super T> onNext) {
return new AutoDisposeFlowable<>(upstream, scope).subscribe(onNext);
}
@Override
public Disposable subscribe(
Consumer<? super T> onNext, Consumer<? super Throwable> onError) {
return new AutoDisposeFlowable<>(upstream, scope).subscribe(onNext, onError);
}
@Override
public Disposable subscribe(
Consumer<? super T> onNext, Consumer<? super Throwable> onError, Action onComplete) {
return new AutoDisposeFlowable<>(upstream, scope)
.subscribe(onNext, onError, onComplete);
}
@Override