INNER CODE UNIT · Java

subscribe

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

          public void subscribe(Subscriber<? super T> observer) {
            new AutoDisposeFlowable<>(upstream, scope).subscribe(observer);
          }

          @Override
          public <E extends @NonNull Subscriber<? super T>> E subscribeWith(E observer) {
            return new AutoDisposeFlowable<>(upstream, scope).subscribeWith(observer);
          }

          @Override
          public TestSubscriber<T> test() {
            TestSubscriber<T> ts = new TestSubscriber<>();
            subscribe(ts);
            return ts;
          }

          @Override
          public TestSubscriber<T> test(long initialRequest) {

View source record →