[infinispan-issues] [JBoss JIRA] (ISPN-9811) Implement single response publisher methods

Implement single response publisher methods ------------------------------------------- Key: ISPN-9811 URL: https://issues.jboss.org/browse/ISPN-9811 Project: Infinispan Issue Type: Sub-task Components: Publisher Reporter: William Burns Assignee: William Burns Priority: Major Fix For: 10.0.0.Beta1, 10.0.0.Final We need to implement the backend for a method like {code} <R> CompletionStage<R> compose(Function<? super Publisher<T>, ? extends CompletionStage<R>> transformer, Function<? super Publisher<R>, ? extends CompletionStage<R>> finalizer); {code} This would allow for all methods that don't require streaming results to be done very easily. For example a count method can then just be implemented by doing: {code} java.util.function.Function<Publisher<?>, CompletionStage<Long>> transformer = cp -> Flowable.fromPublisher(cp) .count() .to(RxJavaInterop.singleToCompletionStage()); java.util.function.Function<Publisher<Long>, CompletionStage<Long>> finalizer = results -> Flowable.fromPublisher(results) .reduce((long) 0, Long::sum) .to(RxJavaInterop.singleToCompletionStage()); return infinispanPublisher.compose(transformer, finalizer); {code}