Details
-
Sub-task
-
Resolution: Done
-
Major
-
None
-
None
-
DataGrid Sprint #29
Description
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);