Reactive Stream Libraries - The canonical reactive streams library for JavaScript, providing observable sequences for composing asynchronous programs.
Functional Reactive Programming - Provides a comprehensive toolkit of operators for composing asynchronous data streams in a functional, declarative style.
Stream Composition Libraries - Implements a chainable operator API for composing stream transformations with backpressure and error recovery.
Reactive Stream Subscribers - Attach an observer to an observable sequence so it reacts to emitted items as they become available, without blocking.
Observable Frameworks - Ships a full observable framework with lazy evaluation, subscription lifecycle management, and cancellation support.
Reactive Stream Buffers - Operators like buffer and window collect emissions into batches, allowing downstream consumers to control flow without dropping data.
Stream Operator Chains - Link operators sequentially so each transforms the output of the previous one, with order affecting the final result.
Asynchronous Operation Chaining - Each operator returns a new observable that wraps the previous one, enabling a composable chain without mutating the source.
Scheduler-Based Concurrency Models - Execution context is abstracted into schedulers that control timing and parallelism, decoupling observable logic from async mechanisms.
Reactive Stream Lifecycles - Managing when and how data emissions start, propagate, and terminate through subscription lifecycle and backpressure patterns.
Subscription Teardown Propagations - Cancelling a subscription triggers a teardown function that propagates through the operator chain, releasing resources upstream.
Stream Error Signaling - Define callbacks for successful completion and error notifications, which terminate the stream after the final emission.
Error Shortcut Terminations - Errors skip all subsequent operators in the chain and immediately notify the observer, with no recovery unless a retry operator is inserted.
Subscription Cancellation Cascades - Stop an observer from receiving further emissions and cascade the cancellation through the operator chain.
Push-Pull Duality - Observables lazily push values to observers on subscription, while pull-based schedulers control when values are produced.
Reactive Data Streams - Building event-driven applications by composing asynchronous data streams with operators for transformation, combination, and error handling.
Signal Hot Conversion - Connectable observables use a shared subscription and a count-based ref counting mechanism to transition from per-subscriber to shared execution.
Subscription-Triggered Emissions - Configure an observable to begin emitting items immediately upon creation, only upon subscription, or only after an explicit connect call.
Subscription Lifecycle Management - Creating, cancelling, and cleaning up observer subscriptions to prevent memory leaks and control resource usage.
Stream Combinators - Apply operators that map, filter, merge, or otherwise manipulate emitted items in a declarative chain.
Exponential Backoff Retries - Retry a failed observable operation after a delay that increases with each attempt, preventing immediate repeated failures.
Retry and Fallback Strategies - Handling failures in asynchronous pipelines with retry logic, fallback observables, and incremental backoff strategies.
