Создание Observable из значений, коллекций, таймеров и Promise.
● of ● from ● range ● interval ● timer ● defer ● EMPTY ● throwError 操 Transformation · 変換
0/23 Преобразование значений потока: map, scan, pairwise, batching.
● map ● scan ● pairwise ● bufferCount ● buffer ● bufferTime ● bufferToggle ● bufferWhen ● count ● dematerialize ● groupBy ● mapTo ● materialize ● pluck ● reduce ● timeInterval ● timestamp ● toArray ● window ● windowCount ● windowTime ● windowToggle ● windowWhen Отбор значений по предикату, ограничение по количеству и времени.
● filter ● take ● takeUntil ● skip ● debounceTime ● throttleTime ● distinctUntilChanged ● first ● audit ● auditTime ● debounce ● distinct ● distinctUntilKeyChanged ● elementAt ● find ● findIndex ● ignoreElements ● isEmpty ● last ● sample ● sampleTime ● single ● skipLast ● skipUntil ● skipWhile ● takeLast ● takeWhile ● throttle Higher-order Observable: switchMap, mergeMap, concatMap, exhaustMap.
● switchMap ● mergeMap ● concatMap ● exhaustMap ● concatAll ● concatMapTo ● exhaust ● exhaustAll ● expand ● flatMap ● mergeAll ● mergeMapTo ● mergeScan ● switchAll ● switchMapTo ● switchScan Объединение нескольких потоков в один.
● combineLatest ● forkJoin ● merge ● concat ● zip ● withLatestFrom ● startWith ● combineAll ● combineLatestAll ● combineLatestWith ● concatWith ● endWith ● mergeWith ● partition ● race ● raceWith ● sequenceEqual ● zipAll ● zipWith 高 Errors & Utility · エラー
0/19 Обработка ошибок и вспомогательные операторы.
● catchError ● retry ● finalize ● tap ● delay ● defaultIfEmpty ● delayWhen ● every ● max ● min ● observeOn ● onErrorResumeNext ● repeat ● repeatWhen ● retryWhen ● subscribeOn ● throwIfEmpty ● timeout ● timeoutWith Один источник — много подписчиков.
● share ● shareReplay ● connect ● multicast ● publish ● publishBehavior ● publishLast ● publishReplay ● refCount