search

reaqtive / reaqtor

Reaqtor is a framework for reliable, stateful, distributed, and scalable event processing based on Rx.
https://reaqtive.net/
MIT License
627 stars 40 forks source link

Operator: Append #87

Open carmeleve opened 3 years ago

carmeleve commented 3 years ago

Link to Rx.NET implementation

bartdesmet commented 3 years ago

Note for implementers, this is a little tricky because the operator goes through some state transitions in its subscription tree. However, one can have a look at StartWith to understand the complexity (and to see an example of how we do fine-grained OnNext calls to drain the array, allowing for scheduler responsiveness when attempting to perform a pause operation).