-
Notifications
You must be signed in to change notification settings - Fork 7.6k
Operator Matrix
David Karnok edited this page Jan 14, 2020
·
31 revisions
Operator | Flowable |
Observable |
Maybe |
Single |
Completable |
---|---|---|---|---|---|
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