-
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
|
|
||||
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