<div dir="ltr"><div><div><div><div>Hello everyone,<br><br></div>I wanted to let you know I wrote up a design documenting the successor to EntryRetriever, Distributed Streams [1] !<br><br></div>Any comments or feedback would be much appreciated.<br><br></div><div>I especially would like targeted feedback regarding:<br><br></div><div>1. The operators forEach and peek may want to be ran locally.  Should we have an overridden method so users can pick which they want?  Personally I feel that peek is too specific to matter and forEach can always be done by the caller locally if desired.<br></div><div>2. The intermediate operators limit and skip do not seem worth implementing unless we have sorting support. (Sorting support will come later).  I am thinking to not support these until sorting is added.<br></div><div><br></div>Thanks,<br><br></div> - Will<br><div><div><br>[1] <a href="https://github.com/infinispan/infinispan/wiki/Distributed-Stream-Support">https://github.com/infinispan/infinispan/wiki/Distributed-Stream-Support</a><br></div></div></div>