Implement streaming response publisher method

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:

<R> Publisher<R> compose(Function<? super Publisher<T>, ? extends Publisher<R>> publisherFunction);