@Test public void reducerNull() { TestSubscriber<Object> ts = new TestSubscriber<>(); Multi.range(1, 5) .reduce((a, b) -> null) .subscribe(ts); ts.assertFailure(NullPointerException.class); }
@Override public void subscribe(Flow.Subscriber<? super T> subscriber) { source.subscribe(new ReducerSubscriber<>(subscriber, reducer)); }
MultiReduce extends CompletionSingle<T> { @Override public void subscribe(Flow.Subscriber<? super T> subscriber) { source.subscribe(new ReducerSubscriber<>(subscriber, reducer)); } }
MultiReduce extends CompletionSingle<T> { @Override public void subscribe(Flow.Subscriber<? super T> subscriber) { source.subscribe(new ReducerSubscriber<>(subscriber, reducer)); } MultiReduce(Multi<T> source, BiFunction<T, T, T> reducer); }
MultiReduce extends CompletionSingle<T> { @Override public void subscribe(Flow.Subscriber<? super T> subscriber) { source.subscribe(new ReducerSubscriber<>(subscriber, reducer)); } MultiReduce(Multi<T> source, BiFunction<T, T, T> reducer); @Override void subscribe(Flow.Subscriber<? super T> subscriber); }
MultiReduce extends CompletionSingle<T> { @Override public void subscribe(Flow.Subscriber<? super T> subscriber) { source.subscribe(new ReducerSubscriber<>(subscriber, reducer)); } MultiReduce(Multi<T> source, BiFunction<T, T, T> reducer); @Override void subscribe(Flow.Subscriber<? super T> subscriber);  }