Migration to 0.9 streams API.

Please check over particularly with respect to correctly closing the resources and shutting down the actor system.
Yeah - couldn't re-write as connect.run so leaving it like this - will fix again when I circle around for 0.10