Currently the $all stream selector subscribe a client to all existing streams at the request moment but the client is not subscribed to the streams that are created after the request.
It is easily implementable by subscribing to the __sled_default tree and check all newly created streams, the problem is that the sled Subscribe API is blocking. It will be mush easily implementable when the Subscriber will use the Futures API.
Currently the
$allstream selector subscribe a client to all existing streams at the request moment but the client is not subscribed to the streams that are created after the request.It is easily implementable by subscribing to the
__sled_defaulttree and check all newly created streams, the problem is that the sled Subscribe API is blocking. It will be mush easily implementable when the Subscriber will use the Futures API.