Reactive pattern

A combination of positive points from the Observer pattern, Iterator pattern, and FP. Supports asynchronous non-blocking communication with backpressure.