package Ġcom . riv uch k . pack tp ub . reactive kotlin . chapter 0 4 Ċ Ċ import Ġio . reactivex . Back pressure Strategy Ċ import Ġio . reactivex . Flow able Ċ import Ġio . reactivex . Observable Ċ import Ġio . reactivex . schedul ers . Schedulers Ċ import Ġkotlinx . coroutines . experimental . delay Ċ import Ġkotlinx . coroutines . experimental . run Blocking Ċ Ċ fun Ġmain ( args : ĠArray < String >) Ġ{ ĊĠĠ ĠObservable . range ( 1 , 1 0 0 0 )// ( 1 ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. map Ġ{ ĠMy Item 3 ( it ) Ġ}// ( 2 ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. observe On ( Schedulers . computation ()) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. subscribe ({ // ( 3 ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġprint (" Received Ġ$ it ;\ t ") ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġrun Blocking Ġ{ Ġdelay ( 5 0 ) Ġ}// ( 4 ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ},{ it . printStackTrace () }) ĊĠĠĠ Ġrun Blocking Ġ{ Ġdelay ( 8 0 0 0 0 ) Ġ}// ( 5 ) Ċ } ĊĊ Ċ data Ġclass ĠMy Item 3 Ġ( val Ġid : Int ) Ġ{ ĊĠĠĠ Ġinit Ġ{ ĊĠĠĠĠĠĠĠ Ġprint (" My Item ĠCreated Ġ$ id ;\ t ") ĊĠĠĠ Ġ} Ċ } Ċ