You can already get a long way towards channels by using reactive extensions (E....

theflagbug · on Jan 28, 2015

Not sure if you're aware, but your Rx example has a few problems:

1.) In the StartSenders method, you're violating the Rx grammar by calling channel.OnNext concurrently. Wrap it on a lock statement.

2) In StartReceiver you're missing out messages the way you handle the channel. Replace the loop with a call to channel.Subscribe

Cakez0r · on Jan 29, 2015

I did not know either of those things! Thanks!