Allows for composing asynchronous and event-based programs using observable sequences.

Library for building reactive fast-data applications.

Provides a standard for asynchronous stream processing with non-blocking backpressure.