Benchmark January 18, 2017

[akarnokd]

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: