/RxJava

RxJava2 示例代码

Primary LanguageJava

RxJava2 示例代码

操作符相关

创建操作符

create()

just()

fromArray()

fromIterable()

fromCallable()

fromFuture()

defer()

timer()

interval()

intervalRange()

range()

rangeLong()

empty()

never()

error()

转换操作符

map()

flatMap()

concatMap()

buffer()

groupBy()

scan()

window()

组合操作符

concat()

concatArray()

merge()

mergeArray()

concatArrayDelayError()

mergeArrayDelayError()

zip()

combineLatest()

combineLatestDelayError()

reduce()

collect()

count()

功能操作符

delay()

doOnEach()

doOnNext()

doAfterNext()

doOnComplete()

doOnError()

doOnSubscribe()

doOnDispose()

doOnLifecycle()

doOnTerminate()

doAfterTerminate()

doFinally()

onErrorReturn()

onErrorResumeNext()

onExceptionResumeNext()

retry()

retryUntil()

retryWhen()

repeat()

repeatWhen()

subscribeOn()

observeOn()

过滤操作符

filter()

ofType()

skip()

skipLast()

distinct()

distinctUntilChanged()

take()

debounce()

firstElement()

lastElement()

elementAt()

elementAtOrError()

条件操作符

all()

takeWhile()

skipWhile()

takeUntil()

skipUntil()

sequenceEqual()

contains()

isEmpty()

amb()

defaultIfEmpty()

背压策略相关

实战相关