Complete removal of MessageSink

This all now works with Observables instead.