You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
What I'm trying to achieve is to create a custom builder interface/wrapper around streamz to have predefined building blocks of preconfigured streams which can be used together. Example
However it looks like the code inside those functions does not alter the initial stream object and all emitted events go straight to sink. What am I doing wrong? Can you please point me in right direction?
Another question, what is the difference between
stream = Stream()
stream.sink(print)
for event in events:
stream.emit(event)
and
stream = Stream()
stream = stream.sink(print) # any other function map/filter/etc. here
for event in events:
stream.emit(event)
I feel like the answer is somewhere in this example but don't understand where. Thanks!
The text was updated successfully, but these errors were encountered:
Hi, thanks for the great project!
What I'm trying to achieve is to create a custom builder interface/wrapper around streamz to have predefined building blocks of preconfigured streams which can be used together. Example
However it looks like the code inside those functions does not alter the initial stream object and all emitted events go straight to sink. What am I doing wrong? Can you please point me in right direction?
Another question, what is the difference between
and
I feel like the answer is somewhere in this example but don't understand where. Thanks!
The text was updated successfully, but these errors were encountered: