Examples from Chapter 11 (Reactive Extensions) of Programming C# 12.0 (O'Reilly).
- Example 1. IObservable<T> and IObserver<T>
- Example 2. Simple IObserver<T> implementation
- Example 3. A simple cold observable source
- Example 4. Attaching an observer to an observable
- Example 5. A cold observable representing a file’s contents
- Example 6. Handling filesystem errors but not observer errors
- Example 7. IObservable<T> for monitoring keypresses
- Example 8. Attaching an observer to an observable
- Example 9. Delegate-based observable source
- Example 10. Delegate-based hot source
- Example 11. Subscribing without implementing IObserver<T>
- Example 19. Smoothing input with Buffer
- Example 20. Smoothing with Window
- Example 21. Breaking text into words with windows
- Example 22. Word breaking with Buffer
- Example 23. Simple stock trade with test stream
- Example 24. Summing with Aggregate
- Example 25. Running total with Scan
- Example 26. ObserveOn
- Example 27. ObserveOn WPF Dispatcher
- Example 28. Observing on the current dispatcher
- Example 30. Converting an IEnumerable<T> to an IObservable<T>
- Example 31. How ToObservable might look without scheduler support
- Example 32. Using an IObservable<T> as an IEnumerable<T>
- Example 33. Wrapping an event in an IObservable<T>
- Example 34. Wrapping a Task<T> as an IObservable<T>
- Example 35. Creating a new task for each subscriber