I'm trying to turn the redis subscription from StackExchange.Redis in to a source. When a user calls subscribe for a particular channel, they pass in the channel they wish to subscribe to, an action which is called when a message is published to the channel and a set of command flags. Given that multiple subscribers can be attached to one channel, I am wondering what the best way of turning this in to a source would be. The subscribers can fluctuate thoughout the lifetime of the program. Any pointers appreciated.