package Ġchapter 0 3 Ċ Ċ import Ġio . reactivex . Observable Ċ import Ġio . reactivex . functions . Bi Function Ċ Ċ class ĠReduce Example Ġ{ ĊĠĠĠ Ġfun Ġmar ble Diagram () Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġb alls Ġ= ĠarrayOf (" 1 ", Ġ" 3 ", Ġ" 5 ") ĊĠĠĠĠĠĠĠ Ġval Ġsource Ġ= ĠObservable . from Array (* b alls ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. reduce { Ġball 1 , Ġball 2 Ġ-> Ġ"$ ball 2 ($ ball 1 ) "} ĊĠĠĠĠĠĠĠ Ġsource . subscribe Ġ{ Ġdata Ġ-> Ġprintln ( data ) Ġ} ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġfun Ġbi Function () Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġmerge B alls Ġ= ĠBi Function < String , ĠString , ĠString > Ġ{ Ġball 1 , Ġball 2 Ġ-> Ġ"$ ball 2 ($ ball 1 )" Ġ} ĊĠĠĠĠĠĠĠ Ġval Ġb alls Ġ= ĠarrayOf (" 1 ", Ġ" 3 ", Ġ" 5 ") ĊĠĠĠĠĠĠĠ Ġval Ġsource Ġ= ĠObservable . from Array (* b alls ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. reduce ( merge B alls ) ĊĠĠĠĠĠĠĠ Ġsource . subscribe Ġ{ Ġdata Ġ-> Ġprintln ( data ) Ġ} ĊĠĠĠ Ġ} Ċ } Ċ Ċ fun Ġmain () Ġ{ ĊĠĠĠ Ġval Ġdemo Ġ= ĠReduce Example () ĊĠĠĠ Ġdemo . mar ble Diagram () ĊĠĠĠ Ġdemo . bi Function () Ċ }