package Ġjp . ac . os aka _ u . sdl . nil . util Ċ Ċ import Ġio . reactivex . rx java 3 . core . Flow able Ċ import Ġio . reactivex . rx java 3 . parallel . Parallel Flow able Ċ Ċ fun Ġ< T > ĠFlow able < T >. parallel If Specified ( threads : ĠInt ): ĠParallel Flow able < T > Ġ= ĊĠĠĠ Ġif Ġ( threads Ġ> Ġ 0 ) Ġ{ ĊĠĠĠĠĠĠĠ Ġparallel ( threads ) ĊĠĠĠ Ġ} Ġelse Ġ{ ĊĠĠĠĠĠĠĠ Ġparallel () ĊĠĠĠ Ġ} Ċ