package Ġoperators . combine Ċ Ċ import Ġio . reactivex . rx java 3 . core . Observable Ċ import Ġio . reactivex . rx java 3 . core . Scheduler Ċ Ċ class ĠMerge Observable Ġ: ĠCombine Observable () Ġ{ ĊĠĠĠ Ġoverride Ġfun Ġimplement Combine ( scheduler : ĠScheduler ): ĠObservable < Pair < Int , ĠString >> Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn ĠObservable . merge ( emit Numbers 1 ( scheduler ), Ġemit Numbers 2 ( scheduler )) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. map Ġ{ Ġit Ġto Ġ" random " Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. do On Next Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġprintln (" number Ġ$ it . first ") ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} Ċ }