Streaming does not support multi shards

[JasonLovesDoggo]

Currently, the streaming impl relies on local channels & maps. We would need to offload the listeners to redis/a pubsub system to scale streaming up