Reactive-Extensions/RxJSArchived

Features

• 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.
• Reactive Programming - Reactive extensions for JavaScript.

Historique des stars