package Ġintro Ċ Ċ import Ġio . reactivex . rx java 3 . core . Flow able Ċ import Ġio . reactivex . rx java 3 . schedul ers . Schedulers Ċ import Ġkotlinx . coroutines . delay Ċ import Ġkotlinx . coroutines . run Blocking Ċ Ċ fun Ġmain () Ġ= Ġrun Blocking Ġ{ ĊĠĠĠ ĠFlow able ĊĠĠĠĠĠĠĠ Ġ. from Callable Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ ĠThread . sleep ( 1 0 0 0 ) Ġ// Ġ Ġim it ate Ġexpensive Ġcomputation ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ" Done " ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠ Ġ. subscribe On ( Schedulers . io ()) ĊĠĠĠĠĠĠĠ Ġ. observe On ( Schedulers . single ()) ĊĠĠĠĠĠĠĠ Ġ. subscribe (:: println , ĠThrowable :: printStackTrace ) ĊĠĠĠ Ġdelay ( 2 0 0 0 ) ĊĠĠĠ Ġprintln (" Demo Ġfinished .") Ċ } ĊĊ