Reactive Programming

3.

Operators: The Language of Streams

3.1.

Role of Operators

3.1.1.

Transforming Streams

3.1.2.

Composing Operations

3.2.

Pipelining Operators (Operator Chaining)

3.2.1.

Chaining Multiple Operators

3.2.2.

Readability and Maintainability

3.3.

Categories of Operators

3.3.1.

Creation Operators

3.3.1.1.

3.3.1.1.1.

Custom Observable Logic

3.3.1.2.

3.3.1.2.1.

Emitting Fixed Values

3.3.1.3.

3.3.1.3.1.

3.3.1.3.2.

3.3.1.3.3.

Futures/Promises

3.3.1.4.

3.3.1.4.1.

Periodic Emissions

3.3.1.5.

3.3.1.5.1.

Delayed Emission

3.3.1.6.

3.3.1.6.1.

No Emissions, Immediate Completion

3.3.1.7.

3.3.1.7.1.

No Emissions, No Completion

3.3.1.8.

3.3.1.8.1.

Immediate Error Emission

3.3.2.

Transformation Operators

3.3.2.1.

3.3.2.1.1.

Value Transformation

3.3.2.2.

3.3.2.2.1.

Flattening Nested Streams

3.3.2.3.

3.3.2.3.1.

Merging Multiple Streams

3.3.2.4.

3.3.2.4.1.

Switching to Latest Stream

3.3.2.5.

3.3.2.5.1.

Sequential Stream Concatenation

3.3.2.6.

3.3.2.6.1.

Accumulating State

3.3.2.7.

3.3.2.7.1.

Collecting Values into Batches

3.3.2.8.

3.3.2.8.1.

Splitting Stream into Windows

3.3.3.

Filtering Operators

3.3.3.1.

3.3.3.1.1.

Conditional Emission

3.3.3.2.

3.3.3.2.1.

Limiting Number of Emissions

3.3.3.3.

3.3.3.3.1.

Emitting Until Condition Met

3.3.3.4.

3.3.3.4.1.

Skipping Initial Emissions

3.3.3.5.

3.3.3.5.1.

Emitting First Value

3.3.3.6.

3.3.3.6.1.

Emitting Last Value

3.3.3.7.

3.3.3.7.1.

Removing Duplicates

3.3.3.8.

distinctUntilChanged

3.3.3.8.1.

Emitting Only Changed Values

3.3.3.9.

3.3.3.9.1.

Emitting After Silence

3.3.3.10.

3.3.3.10.1.

Emitting at Intervals

3.3.4.

Combination Operators

3.3.4.1.

3.3.4.1.1.

Merging Multiple Streams

3.3.4.2.

3.3.4.2.1.

Concatenating Streams

3.3.4.3.

3.3.4.3.1.

Pairing Emissions

3.3.4.4.

3.3.4.4.1.

Combining Latest Values

3.3.4.5.

3.3.4.5.1.

Combining with Latest from Another Stream

3.3.4.6.

3.3.4.6.1.

Prepending Values

3.3.5.

Error Handling Operators

3.3.5.1.

3.3.5.1.1.

Handling Errors

3.3.5.2.

3.3.5.2.1.

Providing Fallback Values

3.3.5.3.

3.3.5.3.1.

Retrying on Error

3.3.5.4.

3.3.5.4.1.

Conditional Retry Logic

3.3.6.

Utility Operators

3.3.6.1.

3.3.6.1.1.

Controlling Subscription Thread

3.3.6.2.

3.3.6.2.1.

Controlling Observer Thread

3.3.6.3.

3.3.6.3.1.

Side Effects for Debugging

3.3.6.4.

3.3.6.4.1.

Delaying Emissions

3.3.6.5.

3.3.6.5.1.

Emitting Errors on Timeout

Previous

2. Core Building Blocks

Go to top

Next

4. Advanced Concepts