INNER CODE UNIT · Java
subscribe
uber/AutoDispose · autodispose/src/main/java/autodispose2/AutoDispose.java:128
public Disposable subscribe(Action action) {
return new AutoDisposeCompletable(upstream, scope).subscribe(action);
}
@Override
public Disposable subscribe(Action action, Consumer<? super Throwable> onError) {
return new AutoDisposeCompletable(upstream, scope).subscribe(action, onError);
}
@Override
public void subscribe(CompletableObserver observer) {
new AutoDisposeCompletable(upstream, scope).subscribe(observer);
}
@Override
public <E extends @NonNull CompletableObserver> E subscribeWith(E observer) {
return new AutoDisposeCompletable(upstream, scope).subscribeWith(observer);
}