@Test public void nullItemMeansEmpty() { TestSubscriber<Object> ts = new TestSubscriber<>(); Single.create(CompletableFuture.completedStage(null), true) .subscribe(ts); ts.assertResult(); }
@Override public void subscribe(Flow.Subscriber<? super T> subscriber) { MultiFromCompletionStage.subscribe(subscriber, source, nullMeansEmpty); }
SingleFromCompletionStage extends CompletionSingle<T> { @Override public void subscribe(Flow.Subscriber<? super T> subscriber) { MultiFromCompletionStage.subscribe(subscriber, source, nullMeansEmpty); } }
SingleFromCompletionStage extends CompletionSingle<T> { @Override public void subscribe(Flow.Subscriber<? super T> subscriber) { MultiFromCompletionStage.subscribe(subscriber, source, nullMeansEmpty); } SingleFromCompletionStage(CompletionStage<T> source, boolean nullMeansEmpty); }
SingleFromCompletionStage extends CompletionSingle<T> { @Override public void subscribe(Flow.Subscriber<? super T> subscriber) { MultiFromCompletionStage.subscribe(subscriber, source, nullMeansEmpty); } SingleFromCompletionStage(CompletionStage<T> source, boolean nullMeansEmpty); @Override void subscribe(Flow.Subscriber<? super T> subscriber); @Override Single<T> cancel(); }
SingleFromCompletionStage extends CompletionSingle<T> { @Override public void subscribe(Flow.Subscriber<? super T> subscriber) { MultiFromCompletionStage.subscribe(subscriber, source, nullMeansEmpty); } SingleFromCompletionStage(CompletionStage<T> source, boolean nullMeansEmpty); @Override void subscribe(Flow.Subscriber<? super T> subscriber); @Override Single<T> cancel();  }