INNER CODE UNIT · Java

CompletableSubscribeProxy

uber/AutoDispose · autodispose/src/main/java/autodispose2/AutoDispose.java:121

        return new CompletableSubscribeProxy() {
          @Override
          public Disposable subscribe() {
            return new AutoDisposeCompletable(upstream, scope).subscribe();
          }

          @Override
          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) {

View source record →