RX-OS // v2.0RxJS NINJA

Creation · 生成

0/8

Creating Observables from values, collections, timers, and Promises.

Transformation · 変換

0/23

Transforming stream values: map, scan, pairwise, batching.

Filtering · 選別

0/28

Selecting values by predicate, limiting by count and time.

Flattening · 平坦化

0/16

Higher-order Observables: switchMap, mergeMap, concatMap, exhaustMap.

Combination · 結合

0/19

Combining several streams into one.

Errors & Utility · エラー

0/19

Error handling and utility operators.

Multicasting · 共有

0/9

One source, many subscribers.

ReferenceraceWith

Reference · 90

raceWith

raceWith

Keeps only the stream that emitted first.

Signature

raceWith(...otherSources: ObservableInputTuple): OperatorFunction

What it does

Subscribes to source and the competing streams. The first source to send a value wins; the rest are unsubscribed.

When to use

Timeout/fallback races, picking the fastest data source, cancelling a slow path with a fast signal.

See also

race, timeout

script.ts // TypeScript

CONSOLE · Console output

Hit Run to see the result...