Skip to content

RxJS Operators

Operators are functions that transform, filter, and combine Observable streams. They’re composed using the pipe() method.

OperatorPurpose
mapTransform each emitted value
filterConditional pass-through
tapSide effects (logging)
debounceTimeIgnore rapid emissions
distinctUntilChangedSkip duplicate values
catchErrorError recovery
retryRetry on failure
takeUntilComplete on condition

Operators are the building blocks for reactive data transformation pipelines.”