INNER CODE UNIT · Java

test

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

          public TestObserver<Void> test(boolean dispose) {
            TestObserver<Void> observer = new TestObserver<>();
            if (dispose) {
              observer.dispose();
            }
            subscribe(observer);
            return observer;
          }
        };
      }

      @Override
      public FlowableSubscribeProxy<T> apply(final Flowable<T> upstream) {
        if (!AutoDisposePlugins.hideProxies) {
          return new AutoDisposeFlowable<>(upstream, scope);
        }
        return new FlowableSubscribeProxy<T>() {
          @Override

View source record →