Non-blocking `For`
emil14 opened this issue · 2 comments
emil14 commented
For
now blocks until all stream elements are processed and then sends a signal - original stream is lost. It's possible to see a different semantics:
For
emits stream (sends original downstream) instead of blocking and sending signal- New
Wait
component is introduced and used for one purpose - block until end of stream
... -> for -> wait -> :stop
emil14 commented
I can see benefit in theory. Example: ... -> for -> map -> ...
. E.g. save every element and mark it as is_saved: true
Much easier than create branching in topology. Also better performance