Benchmark January 18, 2017

# 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](https://gist.github.com/akarnokd/cb9c886fca322abdd6ecb29cca6b6c95)

# 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: