Description
Environment
- i7 4790 stock settings
- Windows 7 x64
- Java 8u112
- library versions: snapshots of their latest major version
- Green: good
- Red: not so good
- Raw data
Async
(Start a stream from the main thread but don't pin the source to it)
versus RxJava 1.x:
versus Reactor-Core:
Pipeline
(Start a stream from a thread, pin it there and observe on a separate thread)
versus RxJava 1.x:
versus Reactor-Core:
Blocking
Empty source
versus RxJava 1.x
versus Reactor-Core:
First element
versus RxJava 1.x:
versus Reactor-Core:
Last element
versus RxJava 1.x:
versus Reactor-Core:
Memory consumption
(Having 1 million active sequences, Megabytes used, smaller is better)
versus RxJava 1.x:
versus Reactor-Core:
Synchronous streaming
range
versus RxJava 1.x:
versus Reactor-Core
fromArray
versus RxJava 1.x:
versus Reactor-Core:
fromIterable
versus RxJava 1.x:
versus Reactor-Core:
concatMap
just
(Concatenate a sequence of values mapped into just())
versus RxJava 1.x:
versus Reactor-Core:
range
(Concatenate a sequence of values expanded into a range())
versus RxJava 1.x:
versus Reactor-Core:
cross-range
(Deliver 1 million items split between a main sequence of length N and its mapping to a 1,000,000 / N inner sequence.
versus RxJava 1.x:
versus Reactor-Core:
flatMap
just
(Merge a sequence of values mapped into just())
versus RxJava 1.x:
versus Reactor-Core:
range
(Merge a sequence of values expanded into a range())
versus RxJava 1.x:
versus Reactor-Core:
cross-range
(Deliver 1 million items split between a main sequence of length N and its mapping to a 1,000,000 / N inner sequence.
versus RxJava 1.x:
versus Reactor-Core:
flatten
(Flatten an mapping to an Iterable inner source)
just
versus RxJava 1.x:
versus Reactor-Core:
range
versus RxJava 1.x:
versus Reactor-Core:
cross-range
versus RxJava 1.x:
versus Reactor-Core:
concatMap vs flatMap
just
range
cross-range
Subject overhead
direct multicast
versus RxJava 1.x:
versus Reactor-Core:
replay
versus RxJava 1.x:
versus Reactor-Core:
unicast
versus RxJava 1.x:
versus Reactor-Core:
async
(Reactor-Core has no AsnycProcessor equivalent)
versus RxJava 1.x:
versus Reactor-Core:
behavior
(Reactor-Core has no BehaviorProcessor equivalent)
versus RxJava 1.x:
versus Reactor-Core:
Subscribe
versus RxJava 1.x:
versus Reactor-Core: