class 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);

}