Re:Reactive Streams for the JVM hits 1.0.0
by fanstatic on Thursday May 07, 2015 @01:01PM
(#9506539)
v1.0.0#specification reads:
> Or another implementation could fuse the operations to the final consumer:
> nioSelectorThreadOrigin | map(f) filter(p) consumeTo(toNioSelectorOutput)
Having control over how to fuse a chain of functions is very interesting. Do any of the implementations allow use of mutable state when fusing a chain of functions with the same signature.
Having control over how to fuse a chain of functions is very interesting. Do any of the implementations allow use of mutable state when fusing a chain of functions with the same signature.