INNER CODE UNIT · Java

test

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

          public TestSubscriber<T> test(long initialRequest, boolean cancel) {
            TestSubscriber<T> ts = new TestSubscriber<>(initialRequest);
            if (cancel) {
              ts.cancel();
            }
            subscribe(ts);
            return ts;
          }
        };
      }

      @Override
      public MaybeSubscribeProxy<T> apply(final Maybe<T> upstream) {
        if (!AutoDisposePlugins.hideProxies) {
          return new AutoDisposeMaybe<>(upstream, scope);
        }
        return new MaybeSubscribeProxy<T>() {
          @Override

View source record →