Design and implement streamer abstraction

[ksysoev]

For WebSocket APIs it's common to stream live updates to client connections.
It'll be useful to create abstraction that will manage listeners for the updates and keep a subscription active until at least one connection is listening to it.

[ksysoev]

Postponing this for now, don't see an elegant abstraction that will provide possibility to implement subscriptions in general way.