package Ġcom . bad oo . reak t ive . benchmarks . j mh . flat map Ċ Ċ import Ġcom . bad oo . reak t ive . observable . Observable Ċ import Ġcom . bad oo . reak t ive . observable . as Observable Ċ import Ġcom . bad oo . reak t ive . observable . flatMap Ċ import Ġcom . bad oo . reak t ive . observable . observable Ċ import Ġcom . bad oo . reak t ive . observable . subscribe Ċ import Ġorg . openjdk . j mh . annotations . Benchmark Ċ Ċ open Ġclass ĠFlat Map Re akt ive Ġ{ ĊĊĠĠĠ Ġ@ Benchmark ĊĠĠĠ Ġfun Ġiterable () Ġ{ ĊĠĠĠĠĠĠĠ ĠFlat Map Config ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. input ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. as Observable () ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. also (:: run ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Benchmark ĊĠĠĠ Ġfun Ġemitter () Ġ{ ĊĠĠĠĠĠĠĠ Ġobservable < Int > Ġ{ Ġemitter Ġ-> ĊĠĠĠĠĠĠĠĠĠĠĠ ĠFlat Map Config . input . forEach ( emitter :: onNext ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġemitter . onComplete () ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. also (:: run ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġprivate Ġfun Ġrun ( input : ĠObservable < Int >) Ġ{ ĊĠĠĠĠĠĠĠ Ġinput ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. flatMap Ġ{ Ġinput Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. subscribe () ĊĠĠĠ Ġ} Ċ } Ċ