Ch11.md

Chapter 11 Examples

Examples from Chapter 11 (Reactive Extensions) of Programming C# 8.0 (O'Reilly).

Fundamental Interfaces

• 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

Publishing and Subscribing with Delegates

• Example 9. Delegate-based observable source
• Example 10. An asynchronous source
• Example 11. Delegate-based hot source
• Example 12. Subscribing without implementing IObserver<T>

Sequence Builders

• Example 13. Generating items
• Example 14. Generating timed items

LINQ Queries

• Example 15. Filtering items with a LINQ query
• Example 16. Capturing the mouse

Grouping Operators

• Example 17. Grouping events

Join Operators

• Example 18. Query expression with join
• Example 19. Join in code
• Example 20. Adding a new line for each drag operation

Rx Query Operators

Merge

• Example 21. Merging observables

Windowing Operators

• Example 22. Smoothing input with Buffer
• Example 23. Smoothing with Window
• Example 24. Breaking text into words with windows
• Example 25. Word breaking with Buffer

The Scan Operator

• Example 26. Simple stock trade with test stream
• Example 27. Summing with Aggregate
• Example 28. Running total with Scan

Schedulers

• Example 29. ObserveOn
• Example 30. WPF-specific ObserveOn overload
• Example 31. Observing on the current dispatcher

Subjects

• Example 32. Implementing IObservable<T> with a Subject<T>
• Example 33. Providing an IObservable<T> as a property

Adaptation

• Example 34. Converting an IEnumerable<T> to an IObservable<T>
• Example 35. How ToObservable might look without scheduler support
• Example 36. Using an IObservable<T> as an IEnumerable<T>
• Example 37. Wrapping an event in an IObservable<T>
• Example 38. Delegate-based event wrapping
• Example 39. Wrapping a Task<T> as an IObservable<T>
• Example 40. Creating a new task for each subscriber

Timed Operations

• Example 41. Regular items with Interval
• Example 42. Two subscribers for one Interval source
• Example 43. Calculating words per minute
• Example 44. Single item with Timer
• Example 45. Timestamped items
• Example 46. Measuring the gaps
• Example 47. Timed windows with Buffer
• Example 48. Overlapping timed windows