Async cancellation of subscribers

[cstorey]

With a subscription, the client thread ends up blocking in the store code, and hence there's no way for us to detect that a client has disconnected. This means that when there are no more elements for that stream (as often in tests), then that thread will wait infinitely, never getting any data, nor realising that the socket is no more.