# btroncone/learn-rxjs

**Attribution required: if you use, quote, or summarise this content, you must credit and link back to [awesome-repositories.com](https://awesome-repositories.com/repository/btroncone-learn-rxjs).**

3,671 stars · 405 forks · TypeScript · MIT

## Links

- GitHub: https://github.com/btroncone/learn-rxjs
- Homepage: https://www.learnrxjs.io
- awesome-repositories: https://awesome-repositories.com/repository/btroncone-learn-rxjs.md

## Topics

`javascript` `learning-rxjs` `observables` `reactive-programming` `rxjs`

## Description

This project is a comprehensive learning resource and technical reference for reactive programming with RxJS. It provides a structured curriculum, curated examples, and an indexed operator catalog to help developers shift from imperative to declarative programming using observable data streams and functional operators.

The repository features a library of reactive UI patterns and implementation recipes. These cover practical applications such as type-ahead search, game loops, gesture-based interactions like swipe-to-refresh, and security overlays like lockscreens.

The resource covers a broad range of reactive capabilities, including stream creation, transformation, and combination. It also details state management, multicasting strategies, and stream control mechanisms for regulating timing, error recovery, and side-effect execution.

## Tags

### Software Engineering & Architecture

- [Observable Streams](https://awesome-repositories.com/f/software-engineering-architecture/flow-modularization/modular-flow-composition/observable-streams.md) — Models asynchronous events as observable data streams that can be transformed and combined using functional operators.
- [Reactive Data Streams](https://awesome-repositories.com/f/software-engineering-architecture/reactive-data-streams.md) — Provides a comprehensive technical reference for composing complex event flows using reactive data streams. ([source](https://www.learnrxjs.io/learn-rxjs/operators))
- [Error Interception Handlers](https://awesome-repositories.com/f/software-engineering-architecture/api-error-handling-patterns/error-interception-handlers.md) — Provides programmable handlers that intercept stream failures to implement global error logic or fallbacks. ([source](https://www.learnrxjs.io/learn-rxjs/operators/error_handling))
- [Multicast Stream Management](https://awesome-repositories.com/f/software-engineering-architecture/multicast-stream-management.md) — Implements multicasting strategies and shared execution paths to optimize observable data streams. ([source](https://cdn.jsdelivr.net/gh/btroncone/learn-rxjs@master/README.md))
- [Multicast Stream Sharing](https://awesome-repositories.com/f/software-engineering-architecture/multicast-stream-sharing.md) — Implements mechanisms to share a single asynchronous data source among multiple subscribers to avoid redundant side effects.
- [Reactive State Management](https://awesome-repositories.com/f/software-engineering-architecture/reactive-state-management.md) — Implements reactive state management using reducer functions to accumulate evolving application state. ([source](https://www.learnrxjs.io/learn-rxjs/recipes/catch-the-dot-game))
- [Latest State Tracking](https://awesome-repositories.com/f/software-engineering-architecture/reactive-state-subscriptions/latest-state-tracking.md) — Implements state tracking that provides subscribers with the most recent context immediately upon subscription. ([source](https://www.learnrxjs.io/learn-rxjs/subjects/subject))
- [Reactive Value Combinations](https://awesome-repositories.com/f/software-engineering-architecture/reactive-value-declarations/reactive-value-combinations.md) — Provides operators to join data from multiple asynchronous sources by coordinating emission order and timing. ([source](https://www.learnrxjs.io/learn-rxjs/operators/combination))
- [Stream Emission Delaying](https://awesome-repositories.com/f/software-engineering-architecture/stream-emission-delaying.md) — Provides capabilities to postpone the delivery of values using specified durations or secondary observable triggers. ([source](https://www.learnrxjs.io/learn-rxjs/operators/utility))
- [Stream Emission Timing Control](https://awesome-repositories.com/f/software-engineering-architecture/stream-emission-timing-control.md) — Regulates the timing and spacing of data emissions using debouncing and throttling to manage UI and network traffic.
- [Observable Emission Filtering](https://awesome-repositories.com/f/software-engineering-architecture/stream-emission-timing-control/observable-emission-filtering.md) — Implements a wide array of filtering operators to control which stream emissions reach the final observer. ([source](https://www.learnrxjs.io/learn-rxjs/operators/filtering))
- [Stream Failure Recovery](https://awesome-repositories.com/f/software-engineering-architecture/stream-failure-recovery.md) — Implements mechanisms for handling asynchronous data stream failures by switching to fallback values or retrying.
- [Stream Operator Chains](https://awesome-repositories.com/f/software-engineering-architecture/stream-piping/function-composition-operators/stream-operator-chains.md) — Implements sequences of stream processing operators where the output of one function becomes the input of the next.
- [Stream State Accumulation](https://awesome-repositories.com/f/software-engineering-architecture/stream-state-accumulation.md) — Maintains and updates application state by reducing stream emissions into a single evolving value.
- [Stream Timing Regulation](https://awesome-repositories.com/f/software-engineering-architecture/stream-timing-regulation.md) — Provides advanced timing regulation using debouncing, throttling, and sampling to manage data flow. ([source](https://www.learnrxjs.io/learn-rxjs/concepts/time-based-operators-comparison))
- [Functional Stream Transformations](https://awesome-repositories.com/f/software-engineering-architecture/streaming-data-transformations/functional-stream-transformations.md) — Provides a comprehensive set of operators to reshape and map emitted values using projection functions. ([source](https://www.learnrxjs.io/learn-rxjs/concepts/get-started-transforming))
- [Game Loop Implementations](https://awesome-repositories.com/f/software-engineering-architecture/event-driven-agent-loops/game-loop-implementations.md) — Coordinates physics and rendering by synchronizing timed intervals with user input streams in a reactive game loop.
- [Stopwatch Implementations](https://awesome-repositories.com/f/software-engineering-architecture/reactive-programming-implementations/stopwatch-implementations.md) — Provides a practical recipe for building a startable and resettable stopwatch using reactive streams. ([source](https://www.learnrxjs.io/learn-rxjs/recipes/stop-watch))
- [Game Loop Updates](https://awesome-repositories.com/f/software-engineering-architecture/reactive-update-scheduling/update-cycle-controllers/update-application-timing/animation-frame-synchronization/game-loop-updates.md) — Implements game loop updates that synchronize logic execution on every frame with user inputs. ([source](https://www.learnrxjs.io/learn-rxjs/recipes/tetris-game))
- [Value Aggregations](https://awesome-repositories.com/f/software-engineering-architecture/reactive-value-declarations/reactive-value-emission/value-aggregations.md) — Implements capabilities to aggregate multiple stream emissions into arrays or accumulated values based on time or count. ([source](https://www.learnrxjs.io/learn-rxjs/operators/transformation))
- [Stream Side Effects](https://awesome-repositories.com/f/software-engineering-architecture/side-effect-handlers/side-effect-execution-encapsulation/stream-side-effects.md) — RxJS capability to perform specific actions during value emission without modifying the stream or affecting downstream subscribers. ([source](https://www.learnrxjs.io/learn-rxjs/operators/utility))
- [Completion Value Emissions](https://awesome-repositories.com/f/software-engineering-architecture/stream-completion-signaling/completion-value-emissions.md) — Enables the delivery of a single terminal value to observers only after the stream terminates. ([source](https://www.learnrxjs.io/learn-rxjs/subjects/asyncsubject))
- [Stream Completion Handlers](https://awesome-repositories.com/f/software-engineering-architecture/stream-completion-signaling/stream-completion-handlers.md) — Implements final cleanup tasks and notifications that trigger once an observable terminates. ([source](https://www.learnrxjs.io/learn-rxjs/operators/utility))
- [Stream Element Grouping](https://awesome-repositories.com/f/software-engineering-architecture/stream-element-grouping.md) — Implements capabilities to split a single stream into multiple observables based on shared keys or partitioning criteria. ([source](https://www.learnrxjs.io/learn-rxjs/operators/transformation))
- [Stream Timeout Enforcement](https://awesome-repositories.com/f/software-engineering-architecture/stream-timeout-enforcement.md) — Implements timeout mechanisms to trigger fallback actions if a stream remains silent for too long. ([source](https://www.learnrxjs.io/learn-rxjs/operators/utility))
- [Stream-to-Promise Conversions](https://awesome-repositories.com/f/software-engineering-architecture/stream-to-promise-conversions.md) — Provides utility operators to convert observable sequences into single promises that resolve upon completion. ([source](https://www.learnrxjs.io/learn-rxjs/operators/utility))

### Data & Databases

- [Nested Stream Flattening](https://awesome-repositories.com/f/data-databases/nested-stream-flattening.md) — Provides patterns for flattening nested observables into a single output stream using various switching strategies.

### DevOps & Infrastructure

- [Reactive Stream Retries](https://awesome-repositories.com/f/devops-infrastructure/restart-automation/process-restarts/restart-strategies/reactive-stream-retries.md) — Implements logic to restart failed observable streams a specific number of times before final failure. ([source](https://www.learnrxjs.io/learn-rxjs/operators/error_handling))
- [History Buffering](https://awesome-repositories.com/f/devops-infrastructure/data-throughput-optimizers/backpressure-controllers/reactive-stream-buffers/history-buffering.md) — Provides implementation recipes for recording and replaying stream emissions to recover missed data. ([source](https://www.learnrxjs.io/learn-rxjs/subjects/subject))

### Education & Learning Resources

- [Asynchronous Stream Guides](https://awesome-repositories.com/f/education-learning-resources/asynchronous-stream-guides.md) — Provides a technical resource for managing timing, error handling and multicasting in complex asynchronous event flows.
- [Reactive Programming Curricula](https://awesome-repositories.com/f/education-learning-resources/reactive-programming-curricula.md) — Provides a structured curriculum for shifting from imperative to declarative programming using observable data streams.
- [RxJS Operator Learning](https://awesome-repositories.com/f/education-learning-resources/rxjs-operator-learning.md) — Provides a collection of curated examples, technical primers and executable code recipes for mastering RxJS.
- [Operator Reference Catalogs](https://awesome-repositories.com/f/education-learning-resources/rxjs-operator-learning/operator-reference-catalogs.md) — Provides an indexed reference of observable operators with practical implementations for filtering, transforming and combining data.

### Web Development

- [Initial State Injections](https://awesome-repositories.com/f/web-development/state-update-handlers/debounced-state-updates/immediate-state-updates/initial-state-injections.md) — Provides mechanisms to deliver the most recent state to new subscribers immediately upon registration. ([source](https://www.learnrxjs.io/learn-rxjs/subjects/behaviorsubject))

### Mobile Development

- [Reactive Search Implementations](https://awesome-repositories.com/f/mobile-development/reactive-search-implementations.md) — Provides a reactive implementation of search input filtering and request delaying to optimize network traffic. ([source](https://www.learnrxjs.io/learn-rxjs/recipes/type-ahead))

### User Interface & Experience

- [Reactive UI Libraries](https://awesome-repositories.com/f/user-interface-experience/reactive-ui-libraries.md) — Ships a library of real-world implementation recipes for building interactive reactive UI components.