Comment Comment by theflagbug 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 parent theflagbug 11 years ago
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