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.

ReferencewindowTime

Reference · 118

windowTime

windowTime

Creates Observable windows by time.

Signature

windowTime(windowTimeSpan: number): OperatorFunction>

What it does

Opens time windows and emits each as an Observable. Source values land in the active window.

When to use

Streaming event processing by time intervals: live analytics, telemetry, batching without arrays.

See also

bufferTime, window

script.ts // TypeScript

CONSOLE · Console output

Hit Run to see the result...