Introduction

The ro library provides all basic operators:

• Creation operators: The data source, usually the first argument of ro.Pipe
• Chainable operators: They filter, validate, transform, enrich... messages
  • Transforming operators: They transform items emitted by an Observable
  • Filtering operators: They selectively emit items from a source Observable
  • Conditional operators: Boolean operators
  • Math and aggregation operators: They perform basic math operations
  • Error handling operators: They help to recover from error notifications from an Observable
  • Combining operators: Combine multiple Observable into one
  • Connectable operators: Convert cold into hot Observable
  • Other: manipulation of context, utility, async scheduling...
• Plugins: External operators (mostly IOs and library wrappers)

Reference

📄️ Introduction

Declarative and composable API

📄️ Creation operators

Create observables from values, iterables, timers, channels, and events.

📄️ Transformation

Transform and reshape stream data into new formats and structures.

📄️ Filtering

Select or skip items using predicates, distinctness, sampling, debounce, throttle.

📄️ Conditional

Evaluate conditions and control stream flow based on boolean logic and comparisons.

📄️ Math

Aggregate numeric streams: sum, average, min/max, count, and reduce.

📄️ Error handling

Catch, retry, fallback, and recover from errors in observable pipelines.

📄️ Combination

Merge, concat, zip, combineLatest, and join multiple streams together.

📄️ Connectable operators

Control subscription sharing and multicasting with subjects and replays.

📄️ Sink

Subscribe to streams and trigger side effects or collect results.

📄️ Context control

Manage context propagation and cancellation across observable streams.

📄️ Utilities

Timeouts, delays, materialize/dematerialize, do/tap, and other helpers.