package Ġcom . bad oo . reak t ive . benchmarks . j mh . filter map Ċ Ċ import Ġio . reactivex . Observable Ċ import Ġorg . openjdk . j mh . annotations . Benchmark Ċ Ċ open Ġclass ĠFilter Map Rx Java 2 Ġ{ ĊĊĠĠĠ Ġ@ Benchmark ĊĠĠĠ Ġfun Ġiterable () Ġ{ ĊĠĠĠĠĠĠĠ ĠObservable ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. from Iterable ( Filter Map Config . input ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. also (:: run ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Benchmark ĊĠĠĠ Ġfun Ġemitter () Ġ{ ĊĠĠĠĠĠĠĠ ĠObservable . create < Int > Ġ{ Ġemitter Ġ-> ĊĠĠĠĠĠĠĠĠĠĠĠ ĠFilter Map Config . input . forEach ( emitter :: onNext ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġemitter . onComplete () ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. also (:: run ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġprivate Ġfun Ġrun ( input : ĠObservable < Int >) Ġ{ ĊĠĠĠĠĠĠĠ Ġinput ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. filter Ġ{ Ġit Ġ% Ġ 2 Ġ== Ġ 0 Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. map Ġ{ Ġit Ġ* Ġ 2 Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. subscribe () ĊĠĠĠ Ġ} Ċ } Ċ