redux-observable/redux-observable

Features

• Observable Middlewares - Extends Redux with an observable-based pipeline to decouple complex business logic from state updates.
• Type-Based Filters - Filters action streams based on the action type to isolate specific events for processing.
• Async Workflow Orchestration - Orchestrates asynchronous streams to manage concurrency, retries, and cancellation of stale requests.
• Stream Combinators - Uses functional operators to merge multiple side-effect streams into a single root observable pipeline.
• Asynchronous Action Handling - Manages the lifecycle of asynchronous operations by transforming action streams into pending, success, or failure states.
• Observable-Based Side Effect Handlers - Defines functions that transform input action streams into output action streams to manage side effects.
• Operator-Based Concurrency Control - Manages task cancellation and race conditions using RxJS functional stream operators.
• Reactive State Management - Implements a reactive architecture for managing application state using RxJS observable primitives.
• Async Action Orchestrators - Transforms streams of Redux actions into new actions through observable-based side-effect pipelines.
• Observable Middleware - Treats Redux action streams as observables to manage complex asynchronous side effects and timing.
• Action Dispatchers - Feeds the output of observable pipelines back into the Redux dispatcher to trigger state updates.
• Side Effect Management Libraries - Decouples business logic from state updates by piping action streams through asynchronous handlers.
• Lazy Side-Effect Loading - Defers the addition of side-effect streams to the middleware until specific features are requested.
• Stream-Based Action Termination - Stops active asynchronous operations mid-flight to prevent stale or unnecessary state updates.
• Stream Compositions - Merges multiple independent observable streams into a single pipeline to coordinate asynchronous logic.
• Dynamic Effect Loading - Supports adding or replacing asynchronous task handlers at runtime to enable code splitting.
• Asynchronous Task Cancellation - Aborts ongoing asynchronous tasks when specific trigger actions occur to prevent race conditions.
• Runtime Effect Injection - Enables replacing or adding to the active root observable stream at runtime for hot reloading.
• Observable Stream Recovery - Captures and recovers from exceptions within observable pipelines to prevent single failures from crashing the system.
• Runtime Side-Effect Swapping - Swaps active side-effect streams at runtime to support dynamic code splitting and hot reloading.
• State Change Observers - Implements mechanisms that trigger reactive pipelines when the application state tree is updated.
• On-Demand State Sampling - Provides a pull-based mechanism to sample the current state value within an observable pipeline on demand.
• State Streaming - Emits the initial value and subsequent updates of the application state as a continuous observable stream.
• Request Cancellation - Provides mechanisms to abort in-flight network requests or background tasks via observable pipelines.
• React - A JavaScript library for building user interfaces - Listed in the “React - A JavaScript library for building user interfaces” section of the Awesome Redux awesome list.
• RxJS - Listed in the “RxJS” section of the Awesome Redux awesome list.
• Side Effects - Listed in the “Side Effects” section of the Awesome Redux awesome list.

Star history