Operator Matrix

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`					⁽²⁶⁾
`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`				⁽²³⁾	⁽⁴⁹⁾
`equals`
`error`
`filter`					⁽³³⁾
`first`			⁽⁵⁰⁾	⁽⁵¹⁾	⁽³⁴⁾
`firstElement`			⁽⁵²⁾	⁽⁵³⁾	⁽²⁾
`firstOrError`			⁽⁵²⁾	⁽⁵³⁾	⁽⁵⁴⁾
`firstOrErrorStage`			⁽⁵⁵⁾	⁽⁵⁵⁾	⁽⁵⁶⁾
`firstStage`			⁽⁵⁵⁾	⁽⁵⁵⁾	⁽⁵⁵⁾
`flatMap`					⁽²⁷⁾
`flatMapCompletable`					⁽²⁷⁾
`flatMapIterable`			⁽²⁸⁾	⁽²⁸⁾	⁽²⁷⁾
`flatMapMaybe`					⁽²⁷⁾
`flatMapObservable`	⁽⁵⁷⁾	⁽⁵⁸⁾			⁽²⁷⁾
`flatMapPublisher`	⁽⁵⁸⁾	⁽⁵⁹⁾			⁽²⁷⁾
`flatMapSingle`					⁽²⁷⁾
`flatMapSingleElement`	⁽⁶⁰⁾	⁽⁶⁰⁾		⁽⁵⁸⁾	⁽²⁷⁾
`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`

Notes

¹ Use contains().
² Always empty.
³ Use concatWith.
⁴ Use blockingFirst(), blockingSingle() or blockingLast().
⁵ Use blockingGet().
⁶ At most one element to get. Use blockingGet().
⁷ No elements to get. Use blockingAwait().
⁸ Use blockingSubscribe()
⁹ Use map() and switchIfEmpty() to transform into a list/collection.
¹⁰ Use map() to transform into a list/collection.
¹¹ Always empty. Use andThen() to bring in a list/collection.
¹² At most one element to store. Use cache().
¹³ At most one element to collect. Use map() and switchIfEmpty() to transform into a list/collection.
¹⁴ One element to collect. Use map() to transform into a list/collection.
¹⁵ Always empty. Use andThen() to bring in a collection.
¹⁶ At most one element per source. Use zip().
¹⁷ Always empty. Use merge().
¹⁸ At most one element per source. Use zipArray().
¹⁹ Always empty. Use mergeArray().
²⁰ Always empty. Use mergeArrayDelayError().
²¹ Always empty. Use mergeDelayError().
²² Use empty().
²³ Never empty.
²⁴ No items to keep ordered. Use mergeArray().
²⁵ No items to keep ordered. Use mergeArrayDelayError().
²⁶ No items to keep ordered. Use merge().
²⁷ Always empty thus no items to map.
²⁸ At most one item. Use flattenAsFlowable or flattenAsObservable.
²⁹ At most one item. Use flattenStreamAsFlowable or flattenStreamAsObservable.
³⁰ 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. Use andThen() to chose the follow-up sequence.
³⁵ At most one item, always distinct.
³⁶ Different terminology. Use doAfterSuccess().
³⁷ Different terminology. Use doAfterNext().
³⁸ Different terminology. Use doOnDispose().
³⁹ Always succeeds or fails, there is no onComplete signal.
⁴⁰ Different terminology. Use doOnCancel().
⁴¹ At most one item. Use doOnEvent().
⁴² Use doOnEach().
⁴³ Different terminology. Use doOnSuccess().
⁴⁴ Backpressure related and not supported outside Flowable.
⁴⁵ Different terminology. Use doOnNext().
⁴⁶ At most one item with index 0. Use defaultIfEmpty.
⁴⁷ Always one item with index 0.
⁴⁸ At most one item with index 0. Use toSingle.
⁴⁹ Use complete().
⁵⁰ At most one item. Use defaultIfEmpty.
⁵¹ Always one item.
⁵² At most one item, would be no-op.
⁵³ Always one item, would be no-op.
⁵⁴ Always empty. Use andThen() and error().
⁵⁵ At most one item. Use toCompletionStage().
⁵⁶ Always empty. Use andThen(), error() and toCompletionStage().
⁵⁷ Not supported. Use flatMap and toFlowable().
⁵⁸ Use flatMap.
⁵⁹ Not supported. Use flatMap and toObservable().
⁶⁰ Use flatMapSingle.
⁶¹ Use flatMapIterable().
⁶² Use flatMapStream().
⁶³ Use subscribe().
⁶⁴ At most one item. Use just() or empty().
⁶⁵ Always one item. Use just().
⁶⁶ Always empty. Use complete().
⁶⁷ Always error.
⁶⁸ Use wrap().

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

Operator Matrix

Notes

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!

Uh oh!

Clone this wiki locally