Browse by Tags
All Tags »
IObserver (
RSS)
Code for this post is available here As promised, here is an example of how to use the ReactiveQueue<T> from RxContrib . Imagine that you have a stateless WCF service that needs to handle a large number of client requests – perhaps, a distributed logging service. Clients need to send messages as quickly as possible and then be on their way. It is up to your service to then do something with those messages. So, assuming we have a logging service, we know several things at this point: it’s a...
Bnaya has released a new version of the RxContrib project which includes the Reactive Queue – an RX interface above a message queue. This version has a provider for CCR ports as the underlying queue mechanism. This provider supports a Port<T> for OnNext notifications, and PortSet<T, Exception> for both OnNext and OnError notifications. To compile, make sure that you have a version of the CCR available (you can download it from here ) and change the appropriate references...
The Rx world is most definitely on fire! Check out Jose’s short-and-sweet implementation of an Event Aggregator using RX. And apparently, we’ll soon see it in Caliburn . Let the good times roll! (Also, check out Bnaya’s introduction and RxContrib ). As the immortal Hannibal Smith once said - “I love it when a plan comes together”.