NotificationsYou must be signed in to change notification settings
Fork7.6k
Star48.5k

Operator Matrix

David Karnok edited this pageJan 30, 2020 ·31 revisions

Operator
`all`			⁽¹⁾	⁽¹⁾	⁽²⁾
`amb`
`ambArray`
`ambWith`
`andThen`	⁽³⁾	⁽³⁾	⁽³⁾	⁽³⁾
`any`			⁽¹⁾	⁽¹⁾	⁽²⁾
`blockingAwait`	⁽⁴⁾	⁽⁴⁾	⁽⁵⁾	⁽⁵⁾
`blockingFirst`			⁽⁶⁾	⁽⁶⁾	⁽⁷⁾
`blockingForEach`			⁽⁸⁾	⁽⁸⁾	⁽⁸⁾
`blockingGet`	⁽⁴⁾	⁽⁴⁾			⁽⁷⁾
`blockingIterable`			⁽⁶⁾	⁽⁶⁾	⁽⁷⁾
`blockingLast`			⁽⁶⁾	⁽⁶⁾	⁽⁷⁾
`blockingLatest`			⁽⁶⁾	⁽⁶⁾	⁽⁷⁾
`blockingMostRecent`			⁽⁶⁾	⁽⁶⁾	⁽⁷⁾
`blockingNext`			⁽⁶⁾	⁽⁶⁾	⁽⁷⁾
`blockingSingle`			⁽⁶⁾	⁽⁶⁾	⁽⁷⁾
`blockingStream`			⁽⁶⁾	⁽⁶⁾	⁽⁷⁾
`blockingSubscribe`
`buffer`			⁽⁹⁾	⁽¹⁰⁾	⁽¹¹⁾
`cache`
`cacheWithInitialCapacity`			⁽¹²⁾	⁽¹²⁾	⁽¹²⁾
`cast`					⁽²⁾
`collect`			⁽¹³⁾	⁽¹⁴⁾	⁽¹⁵⁾
`collectInto`			⁽¹³⁾	⁽¹⁴⁾	⁽¹⁵⁾
`combineLatest`			⁽¹⁶⁾	⁽¹⁶⁾	⁽¹⁷⁾
`combineLatestArray`			⁽¹⁸⁾	⁽¹⁸⁾	⁽¹⁹⁾
`combineLatestArrayDelayError`			⁽¹⁸⁾	⁽¹⁸⁾	⁽²⁰⁾
`combineLatestDelayError`			⁽¹⁶⁾	⁽¹⁶⁾	⁽²¹⁾
`complete`	⁽²²⁾	⁽²²⁾	⁽²²⁾	⁽²³⁾
`compose`
`concat`
`concatArray`
`concatArrayDelayError`
`concatArrayEager`					⁽²⁴⁾
`concatArrayEagerDelayError`					⁽²⁵⁾
`concatDelayError`
`concatEager`					⁽²⁶⁾
`concatEagerDelayError`					⁽²⁷⁾
`concatMap`					⁽²⁸⁾
`concatMapCompletable`					⁽²⁸⁾
`concatMapCompletableDelayError`			⁽²⁹⁾	⁽²⁹⁾	⁽²⁸⁾
`concatMapDelayError`			⁽³⁰⁾	⁽³⁰⁾	⁽²⁸⁾
`concatMapEager`			⁽³¹⁾	⁽³¹⁾	⁽²⁸⁾
`concatMapEagerDelayError`			⁽³¹⁾	⁽³¹⁾	⁽²⁸⁾
`concatMapIterable`			⁽³²⁾	⁽³²⁾	⁽²⁸⁾
`concatMapMaybe`			⁽³³⁾		⁽²⁸⁾
`concatMapMaybeDelayError`			⁽³⁴⁾	⁽³⁴⁾	⁽²⁸⁾
`concatMapSingle`				⁽³⁵⁾	⁽²⁸⁾
`concatMapSingleDelayError`			⁽³⁶⁾	⁽³⁶⁾	⁽²⁸⁾
`concatMapStream`			⁽³⁷⁾	⁽³⁷⁾	⁽²⁸⁾
`concatWith`
`contains`					⁽²⁾
`count`				⁽³⁸⁾	⁽³⁹⁾
`create`
`debounce`			⁽⁴⁰⁾	⁽⁴⁰⁾	⁽⁴¹⁾
`defaultIfEmpty`				⁽²³⁾	⁽⁴²⁾
`defer`
`delay`
`delaySubscription`
`dematerialize`					⁽⁴¹⁾
`distinct`			⁽⁴³⁾	⁽⁴³⁾	⁽⁴¹⁾
`distinctUntilChanged`			⁽⁴³⁾	⁽⁴³⁾	⁽⁴¹⁾
`doAfterNext`			⁽⁴⁴⁾	⁽⁴⁴⁾	⁽²⁾
`doAfterSuccess`	⁽⁴⁵⁾	⁽⁴⁵⁾			⁽⁴¹⁾
`doAfterTerminate`
`doFinally`
`doOnCancel`		⁽⁴⁶⁾	⁽⁴⁶⁾	⁽⁴⁶⁾	⁽⁴⁶⁾
`doOnComplete`				⁽⁴⁷⁾
`doOnDispose`	⁽⁴⁸⁾
`doOnEach`			⁽⁴⁹⁾	⁽⁴⁹⁾	⁽⁴¹⁾
`doOnError`
`doOnEvent`	⁽⁵⁰⁾	⁽⁵⁰⁾
`doOnLifecycle`
`doOnNext`			⁽⁵¹⁾	⁽⁵¹⁾	⁽⁴¹⁾
`doOnRequest`		⁽⁵²⁾	⁽⁵²⁾	⁽⁵²⁾	⁽⁵²⁾
`doOnSubscribe`
`doOnSuccess`	⁽⁵³⁾	⁽⁵³⁾			⁽⁴¹⁾
`doOnTerminate`
`elementAt`			⁽⁵⁴⁾	⁽⁵⁵⁾	⁽⁴¹⁾
`elementAtOrError`			⁽⁵⁶⁾	⁽⁵⁵⁾	⁽⁴¹⁾
`empty`				⁽²³⁾	⁽⁵⁷⁾
`error`
`filter`					⁽⁴¹⁾
`first`			⁽⁵⁸⁾	⁽⁵⁹⁾	⁽⁴²⁾
`firstElement`			⁽⁶⁰⁾	⁽⁶¹⁾	⁽²⁾
`firstOrError`			⁽⁶⁰⁾	⁽⁶¹⁾	⁽⁶²⁾
`firstOrErrorStage`			⁽⁶³⁾	⁽⁶³⁾	⁽⁶⁴⁾
`firstStage`			⁽⁶³⁾	⁽⁶³⁾	⁽⁶³⁾
`flatMap`					⁽²⁸⁾
`flatMapCompletable`					⁽²⁸⁾
`flatMapIterable`			⁽³²⁾	⁽³²⁾	⁽²⁸⁾
`flatMapMaybe`			⁽⁶⁵⁾		⁽²⁸⁾
`flatMapObservable`	⁽⁶⁶⁾	⁽⁶⁷⁾			⁽²⁸⁾
`flatMapPublisher`	⁽⁶⁷⁾	⁽⁶⁸⁾			⁽²⁸⁾
`flatMapSingle`				⁽⁶⁵⁾	⁽²⁸⁾
`flatMapStream`			⁽³⁷⁾	⁽³⁷⁾	⁽²⁸⁾
`flattenAsFlowable`	⁽⁶⁹⁾	⁽⁶⁹⁾			⁽²⁸⁾
`flattenAsObservable`	⁽⁶⁹⁾	⁽⁶⁹⁾			⁽²⁸⁾
`flattenStreamAsFlowable`	⁽⁷⁰⁾	⁽⁷⁰⁾			⁽²⁸⁾
`flattenStreamAsObservable`	⁽⁷⁰⁾	⁽⁷⁰⁾			⁽²⁸⁾
`forEach`			⁽⁷¹⁾	⁽⁷¹⁾	⁽⁷¹⁾
`forEachWhile`			⁽⁷¹⁾	⁽⁷¹⁾	⁽⁷¹⁾
`fromAction`				⁽²³⁾
`fromArray`			⁽⁷²⁾	⁽⁷³⁾	⁽⁷⁴⁾
`fromCallable`
`fromCompletable`				⁽⁷⁵⁾	⁽⁷⁶⁾
`fromCompletionStage`
`fromFuture`
`fromIterable`			⁽⁷²⁾	⁽⁷³⁾	⁽⁷⁴⁾
`fromMaybe`			⁽⁷⁶⁾
`fromObservable`		⁽⁷⁶⁾
`fromOptional`				⁽⁷³⁾	⁽⁷⁴⁾
`fromPublisher`
`fromRunnable`				⁽²³⁾
`fromSingle`				⁽⁷⁶⁾
`fromStream`			⁽⁷²⁾	⁽⁷³⁾	⁽⁷⁴⁾
`fromSupplier`
`generate`			⁽⁷⁷⁾	⁽⁷⁷⁾	⁽⁷⁷⁾
`groupBy`			⁽⁷⁸⁾	⁽⁷⁸⁾	⁽⁷⁹⁾
`groupJoin`			⁽⁷⁸⁾	⁽⁷⁸⁾	⁽⁸⁰⁾
`hide`
`ignoreElement`	⁽⁸¹⁾	⁽⁸¹⁾			⁽²⁾
`ignoreElements`			⁽⁸²⁾	⁽⁸²⁾	⁽²⁾
`interval`			⁽⁸³⁾	⁽⁸³⁾	⁽⁸³⁾
`intervalRange`			⁽⁸³⁾	⁽⁸³⁾	⁽⁸³⁾
`isEmpty`				⁽⁵⁹⁾	⁽²⁾
`join`			⁽⁸⁴⁾	⁽⁸⁴⁾	⁽⁸⁰⁾
`just`					⁽²⁾
`last`			⁽⁵⁸⁾	⁽⁵⁹⁾	⁽⁴²⁾
`lastElement`			⁽⁶⁰⁾	⁽⁶¹⁾	⁽²⁾
`lastOrError`			⁽⁶⁰⁾	⁽⁶¹⁾	⁽⁶²⁾
`lastOrErrorStage`			⁽⁶³⁾	⁽⁶³⁾	⁽⁶⁴⁾
`lastStage`			⁽⁶³⁾	⁽⁶³⁾	⁽⁶³⁾
`lift`
`map`					⁽²⁸⁾
`mapOptional`					⁽²⁸⁾
`materialize`
`merge`
`mergeArray`
`mergeArrayDelayError`
`mergeDelayError`
`mergeWith`
`never`
`observeOn`
`ofType`					⁽⁸⁵⁾
`onBackpressureBuffer`		⁽⁵²⁾	⁽⁵²⁾	⁽⁵²⁾	⁽⁵²⁾
`onBackpressureDrop`		⁽⁵²⁾	⁽⁵²⁾	⁽⁵²⁾	⁽⁵²⁾
`onBackpressureLatest`		⁽⁵²⁾	⁽⁵²⁾	⁽⁵²⁾	⁽⁵²⁾
`onErrorComplete`
`onErrorResumeNext`
`onErrorResumeWith`
`onErrorReturn`
`onErrorReturnItem`
`onTerminateDetach`
`parallel`		⁽⁸⁶⁾	⁽⁸⁶⁾	⁽⁸⁶⁾	⁽⁸⁶⁾
`publish`			⁽⁸⁷⁾	⁽⁸⁸⁾	⁽⁸⁹⁾
`range`			⁽⁹⁰⁾	⁽⁹⁰⁾	⁽⁷⁴⁾
`rangeLong`			⁽⁹⁰⁾	⁽⁹⁰⁾	⁽⁷⁴⁾
`rebatchRequests`		⁽⁵²⁾	⁽⁵²⁾	⁽⁵²⁾	⁽⁵²⁾
`reduce`			⁽⁹¹⁾	⁽⁹¹⁾	⁽⁹²⁾
`reduceWith`			⁽⁹¹⁾	⁽⁹¹⁾	⁽⁹²⁾
`repeat`
`repeatUntil`
`repeatWhen`
`replay`			⁽⁸⁷⁾	⁽⁸⁸⁾	⁽⁸⁹⁾
`retry`
`retryUntil`
`retryWhen`
`safeSubscribe`
`sample`			⁽⁶⁰⁾	⁽⁶⁰⁾	⁽⁴¹⁾
`scan`			⁽⁹¹⁾	⁽⁹¹⁾	⁽⁹²⁾
`scanWith`			⁽⁹¹⁾	⁽⁹¹⁾	⁽⁹²⁾
`sequenceEqual`
`serialize`			⁽⁹³⁾	⁽⁹³⁾	⁽⁹³⁾
`share`			⁽⁸⁷⁾	⁽⁸⁸⁾	⁽⁸⁹⁾
`single`			⁽⁵⁸⁾	⁽⁵⁹⁾	⁽⁴²⁾
`singleElement`			⁽⁶⁰⁾	⁽⁶¹⁾	⁽²⁾
`singleOrError`			⁽⁶⁰⁾	⁽⁶¹⁾	⁽⁶²⁾
`singleOrErrorStage`			⁽⁶³⁾	⁽⁶³⁾	⁽⁶⁴⁾
`singleStage`			⁽⁶³⁾	⁽⁶³⁾	⁽⁶³⁾
`skip`			⁽⁶⁰⁾	⁽⁶⁰⁾	⁽⁶⁰⁾
`skipLast`			⁽⁶⁰⁾	⁽⁶⁰⁾	⁽⁶⁰⁾
`skipUntil`			⁽⁹⁴⁾	⁽⁹⁴⁾	⁽⁹⁴⁾
`skipWhile`			⁽⁹⁵⁾	⁽⁹⁵⁾	⁽²⁾
`sorted`			⁽⁷⁸⁾	⁽⁷⁸⁾	⁽⁷⁸⁾
`startWith`
`startWithArray`			⁽⁹⁶⁾	⁽⁹⁶⁾	⁽⁹⁶⁾
`startWithItem`			⁽⁹⁷⁾	⁽⁹⁷⁾	⁽⁹⁷⁾
`startWithIterable`			⁽⁹⁸⁾	⁽⁹⁸⁾	⁽⁹⁸⁾
`subscribe`
`subscribeOn`
`subscribeWith`
`switchIfEmpty`				⁽²³⁾	⁽⁹⁹⁾
`switchMap`			⁽¹⁰⁰⁾	⁽¹⁰⁰⁾	⁽²⁸⁾
`switchMapCompletable`			⁽¹⁰⁰⁾	⁽¹⁰⁰⁾	⁽²⁸⁾
`switchMapCompletableDelayError`			⁽¹⁰⁰⁾	⁽¹⁰⁰⁾	⁽²⁸⁾
`switchMapDelayError`			⁽¹⁰⁰⁾	⁽¹⁰⁰⁾	⁽²⁸⁾
`switchMapMaybe`			⁽¹⁰⁰⁾	⁽¹⁰⁰⁾	⁽²⁸⁾
`switchMapMaybeDelayError`			⁽¹⁰⁰⁾	⁽¹⁰⁰⁾	⁽²⁸⁾
`switchMapSingle`			⁽¹⁰⁰⁾	⁽¹⁰⁰⁾	⁽²⁸⁾
`switchMapSingleDelayError`			⁽¹⁰⁰⁾	⁽¹⁰⁰⁾	⁽²⁸⁾
`switchOnNext`
`switchOnNextDelayError`
`take`			⁽⁶⁰⁾	⁽⁶⁰⁾	⁽⁶⁰⁾
`takeLast`			⁽⁶⁰⁾	⁽⁶⁰⁾	⁽⁶⁰⁾
`takeUntil`
`takeWhile`			⁽⁹⁵⁾	⁽⁹⁵⁾	⁽²⁾
`test`
`throttleFirst`			⁽⁴⁰⁾	⁽⁴⁰⁾	⁽⁴¹⁾
`throttleLast`			⁽⁴⁰⁾	⁽⁴⁰⁾	⁽⁴¹⁾
`throttleLatest`			⁽⁴⁰⁾	⁽⁴⁰⁾	⁽⁴¹⁾
`throttleWithTimeout`			⁽⁴⁰⁾	⁽⁴⁰⁾	⁽⁴¹⁾
`timeInterval`					⁽⁴¹⁾
`timeout`
`timer`
`timestamp`					⁽⁴¹⁾
`to`
`toCompletionStage`	⁽¹⁰¹⁾	⁽¹⁰¹⁾
`toFlowable`	⁽¹⁰²⁾
`toFuture`
`toList`			⁽¹³⁾	⁽¹⁴⁾	⁽¹⁵⁾
`toMap`			⁽¹³⁾	⁽¹⁴⁾	⁽¹⁵⁾
`toMaybe`	⁽¹⁰³⁾	⁽¹⁰³⁾	⁽¹⁰²⁾
`toMultimap`			⁽¹³⁾	⁽¹⁴⁾	⁽¹⁵⁾
`toObservable`		⁽¹⁰²⁾
`toSingle`	⁽¹⁰⁴⁾	⁽¹⁰⁴⁾		⁽¹⁰²⁾
`toSingleDefault`	⁽¹⁰⁵⁾	⁽¹⁰⁵⁾	⁽¹⁰⁶⁾	⁽¹⁰²⁾
`toSortedList`			⁽¹³⁾	⁽¹⁴⁾	⁽¹⁵⁾
`unsafeCreate`
`unsubscribeOn`
`using`
`window`			⁽¹⁰⁷⁾	⁽¹⁰⁸⁾	⁽¹⁰⁹⁾
`withLatestFrom`			⁽¹⁶⁾	⁽¹⁶⁾	⁽¹⁷⁾
`wrap`	⁽¹¹⁰⁾
`zip`					⁽¹¹¹⁾
`zipArray`					⁽¹¹²⁾
`zipWith`					⁽¹¹³⁾
237 operators	216	210	118	108	84

Notes

¹ Usecontains().
² Always empty.
³ UseconcatWith.
⁴ UseblockingFirst(),blockingSingle() orblockingLast().
⁵ UseblockingGet().
⁶ At most one element to get. UseblockingGet().
⁷ No elements to get. UseblockingAwait().
⁸ UseblockingSubscribe()
⁹ Usemap() andswitchIfEmpty() to transform into a list/collection.
¹⁰ Usemap() to transform into a list/collection.
¹¹ Always empty. UseandThen() to bring in a list/collection.
¹² At most one element to store. Usecache().
¹³ At most one element to collect. Usemap() andswitchIfEmpty() to transform into a list/collection.
¹⁴ One element to collect. Usemap() to transform into a list/collection.
¹⁵ Always empty. UseandThen() to bring in a collection.
¹⁶ At most one element per source. Usezip().
¹⁷ Always empty. Usemerge().
¹⁸ At most one element per source. UsezipArray().
¹⁹ Always empty. UsemergeArray().
²⁰ Always empty. UsemergeArrayDelayError().
²¹ Always empty. UsemergeDelayError().
²² Useempty().
²³ Never empty.
²⁴ No items to keep ordered. UsemergeArray().
²⁵ No items to keep ordered. UsemergeArrayDelayError().
²⁶ No items to keep ordered. Usemerge().
²⁷ No items to keep ordered. UsemergeDelayError().
²⁸ Always empty thus no items to map.
²⁹ Either the upstream fails (thus no inner) or the mapped-in source, but never both. UseconcatMapCompletable.
³⁰ Either the upstream fails (thus no inner) or the mapped-in source, but never both. UseconcatMap.
³¹ At most one item to map. UseconcatMap().
³² At most one item. UseflattenAsFlowable orflattenAsObservable.
³³ UseconcatMap.
³⁴ Either the upstream fails (thus no inner) or the mapped-in source, but never both. UseconcatMapMaybe.
³⁵ UseconcatMap().
³⁶ Either the upstream fails (thus no inner) or the mapped-in source, but never both. UseconcatMapSingle.
³⁷ At most one item. UseflattenStreamAsFlowable orflattenStreamAsObservable.
³⁸ Never empty thus always 1.
³⁹ Always empty thus always 0.
⁴⁰ At most one item signaled so no subsequent items to work with.
⁴¹ Always empty thus no items to work with.
⁴² Always empty. UseandThen() to chose the follow-up sequence.
⁴³ At most one item, always distinct.
⁴⁴ Different terminology. UsedoAfterSuccess().
⁴⁵ Different terminology. UsedoAfterNext().
⁴⁶ Different terminology. UsedoOnDispose().
⁴⁷ Always succeeds or fails, there is noonComplete signal.
⁴⁸ Different terminology. UsedoOnCancel().
⁴⁹ At most one item. UsedoOnEvent().
⁵⁰ UsedoOnEach().
⁵¹ Different terminology. UsedoOnSuccess().
⁵² Backpressure related and not supported outsideFlowable.
⁵³ Different terminology. UsedoOnNext().
⁵⁴ At most one item with index 0. UsedefaultIfEmpty.
⁵⁵ Always one item with index 0.
⁵⁶ At most one item with index 0. UsetoSingle.
⁵⁷ Usecomplete().
⁵⁸ At most one item. UsedefaultIfEmpty.
⁵⁹ Always one item.
⁶⁰ At most one item, would be no-op.
⁶¹ Always one item, would be no-op.
⁶² Always empty. UseandThen() anderror().
⁶³ At most one item. UsetoCompletionStage().
⁶⁴ Always empty. UseandThen(),error() andtoCompletionStage().
⁶⁵ UseflatMap().
⁶⁶ Not supported. UseflatMap andtoFlowable().
⁶⁷ UseflatMap.
⁶⁸ Not supported. UseflatMap andtoObservable().
⁶⁹ UseflatMapIterable().
⁷⁰ UseflatMapStream().
⁷¹ Usesubscribe().
⁷² At most one item. Usejust() orempty().
⁷³ Always one item. Usejust().
⁷⁴ Always empty. Usecomplete().
⁷⁵ Always error.
⁷⁶ Usewrap().
⁷⁷ UsefromSupplier().
⁷⁸ At most one item.
⁷⁹ Always empty thus no items to group.
⁸⁰ Always empty thus no items to join.
⁸¹ UseignoreElements().
⁸² UseignoreElement().
⁸³ At most one item. Usetimer().
⁸⁴ At most one item. Usezip()
⁸⁵ Always empty thus no items to filter.
⁸⁶ Needs backpressure thus not supported outsideFlowable.
⁸⁷ Connectable sources not supported outsideFlowable andObservable. Use aMaybeSubject.
⁸⁸ Connectable sources not supported outsideFlowable andObservable. Use aSingleSubject.
⁸⁹ Connectable sources not supported outsideFlowable andObservable. Use aConnectableSubject.
⁹⁰ At most one item. Usejust().
⁹¹ At most one item. Usemap().
⁹² Always empty thus no items to reduce.
⁹³ At most one signal type.
⁹⁴ At most one item. UsetakeUntil().
⁹⁵ At most one item. Usefilter().
⁹⁶ UsestartWith() andfromArray() ofFlowable orObservable.
⁹⁷ UsestartWith() andjust() of another reactive type.
⁹⁸ UsestartWith() andfromIterable() ofFlowable orObservable.
⁹⁹ Always empty. UsedefaultIfEmpty().
¹⁰⁰ At most one item. UseflatMap().
¹⁰¹ UsefirstStage,lastStage orsingleStage.
¹⁰² Would be no-op.
¹⁰³ UsefirstElement,lastElement orsingleElement.
¹⁰⁴ UsefirstOrError,lastOrError orsingleOrError.
¹⁰⁵ Usefirst,last orsingle.
¹⁰⁶ UsedefaultIfEmpty().
¹⁰⁷ Usemap() andswitchIfEmpty() to transform into a nested source.
¹⁰⁸ Usemap() to transform into a nested source.
¹⁰⁹ Always empty. UseandThen() to bring in a nested source.
¹¹⁰ UsefromPublisher().
¹¹¹ Usemerge().
¹¹² UsemergeArray().
¹¹³ UsemergeWith().

Under development

Currently, all intended operators are implemented.

Copyright (c) 2016-present, RxJava Contributors.
Twitter @RxJava |Gitter @RxJava

Movatterモバイル変換

Operator Matrix

Notes

Under development

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Clone this wiki locally