Mono - Testing
- just
- delay
- add
- delayElement
- delaySubscription
- as
- cast
- create
- block
- empty
- justOrEmpty
- first
- fromSupplier
- fromCallable
- fromRunnable
- fromCompletable
- zip
MonoProcessor - Testing
- block
- toFuture
- subscribe
- doOnSubscribe
- doOnSuccess
- doOnNext
- doOnRequest
- doOnEach
- doOnTerminate
- doOnError
- downstreamCount
- hasDownstreams
Flux - Testing
- never
- just
- fromIterable
- fromArray
- fromStream
- concatWith
- first
- take
- toIterable
- subscribe
- generate
- handle
- using
- range
- doFinally
- onError
- onErrorReturn
- doOnNext
- doOnEach
- doOnCompleted
- doAfterTerminate
- doOnTerminate
- doFinally
- doOnCancel
- doOnSubscribe
- elapse
- retry
- exceptions
- retryWhen
- try-catch
- propagate
- log
- transform
- compose
- merge
- mergeSequential
- publishOn
- subscribeOn
- cancelOn
- prefetch
- defer
EmitterProcessor - Testing
- next
- subscriber
- create
- collectLits
- doOnNext
- doOnSubscribe
- doOnEach
- toFuture
- onNext
Schedulers - Testing
- parallel
- elastic
- inmediate
- fromExecutor
- fromExecutorService
ParallelFlux with Schedulers - Testing
- parallel
- groups
- filter
- collectList
- runOn
- from
- sequential
- dispose
ConnectableFlux - Testing
- connect
- autoConnect
- publish
- subscribe
- sample
- create
References
- https://github.com/vicboma1/Reactive-Programming-with-JDK-9-Flow-API
- https://github.com/reactor/reactor-core
- http://projectreactor.io/docs/core/release/reference/docs/index.html
- https://projectreactor.io/docs/core/release/api/
- https://github.com/reactor/lite-rx-api-hands-on
- https://www.infoq.com/articles/reactor-by-example/
- http://reactivex.io/documentation/operators.html