This project is read-only.
Rx Contrib is ongoing effort for community additions for Rx.
Current features are:
ReactiveQueue: ISubject that does not loose values if there are no subscribers.
The reactive queue is using the IQueueAdapter for injecting concrete
queue adapters. Out of the box it has implementation
upon the ConcurrentQueue which have extreme throughput
(more then 2,000,000 messages of 500 byte per second on basic quad server).
It is also support Weak Subscribe option that holds the subscriber
using week reference, so it remove the subscription after it
been collected.
Amazing online profiling capabilities.

If you want to contribute to this efforts, you can contact

Credits: The Reactive Queue, Weak Subscription, Unsubscribe Disposable are join effort of Bnaya Eshet and Yuval Mazor.
The EventPublisher is owned by José F. Romaniello (
Unwrap: Andreas Köpf

Bnaya Eshet blog:
Yuval Mazor blog:

Last edited Mar 25, 2012 at 1:03 PM by Bnaya, version 6