Explore serving the incoming messages as an observable

Instead of using `HandleMessage<T>`, you would use `.ToObservable()`. You could then use the standard methods like `OfType<MyMessageType>()` and `Where` to do more advanced grouping, buffering, filtering then you would by just using `HandleMessage<T>`.