INNER CODE UNIT · Java

apply

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

      public ParallelFlowableSubscribeProxy<T> apply(final ParallelFlowable<T> upstream) {
        if (!AutoDisposePlugins.hideProxies) {
          return new AutoDisposeParallelFlowable<>(upstream, scope);
        }
        return subscribers ->
            new AutoDisposeParallelFlowable<>(upstream, scope).subscribe(subscribers);
      }

      @Override
      public CompletableSubscribeProxy apply(final Completable upstream) {
        if (!AutoDisposePlugins.hideProxies) {
          return new AutoDisposeCompletable(upstream, scope);
        }
        return new CompletableSubscribeProxy() {
          @Override
          public Disposable subscribe() {
            return new AutoDisposeCompletable(upstream, scope).subscribe();
          }

View source record →