You've switched Types here from `IObservable<T>` to `IObserver<T>` - maybe mention at the top which one you're referring to?