Implement streaming response publisher method --------------------------------------------- Key: ISPN-9812 URL: https://issues.jboss.org/browse/ISPN-9812 Project: Infinispan Issue Type: Sub-task Components: Publisher Reporter: Will Burns Assignee: Ryan Emerson Priority: Major Fix For: 10.1.0.Final We need to implement a streaming based publisher that would support rehash. This is required for exposing the Cache as a Publisher or iterator properly. The example method to allow is quite simple: {code} <R> Publisher<R> compose(Function<? super Publisher<T>, ? extends Publisher<R>> publisherFunction); {code}