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.

ReferencewindowCount

Reference · 117

windowCount

windowCount

Creates fixed-size Observable windows.

Signature

windowCount(windowSize: number, startWindowEvery?: number): OperatorFunction>

What it does

Opens windows by value count. Unlike bufferCount, each window is handed out as an Observable.

When to use

Streaming batch processing without waiting for the full array in one place.

See also

bufferCount, window

script.ts // TypeScript

CONSOLE · Console output

Hit Run to see the result...