An observable is created from the TextChanged event of the TextBox. Also any input is only selected if it's different from the last input and if there was no input within 0.5 seconds.
The output in this example is sent to the console.
Streaming Data from Database with Observable
Assume having a method returning IEnumerable<T>, f.e.
Creates an Observable and starts a method asynchronously. SelectMany flattens the collection and the subscription is fired every 200 elements through Buffer.
This modified text is an extract of the original Stack Overflow Documentation created by following contributors and released under CC BY-SA 3.0