-
Notifications
You must be signed in to change notification settings - Fork 7.6k
Operator Matrix
David Karnok edited this page Jan 21, 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
|
![]() |
![]() |
![]() |
![]() |
![]() |
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
|
![]() |
![]() |
![]() |
![]() |
(1)
|
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
|
![]() |
![]() |
![]() |
![]() |
![]() |
Copyright (c) 2016-present, RxJava Contributors.
Twitter @RxJava | Gitter @RxJava






