package Ġcom . riv uch k . pack tp ub . reactive kotlin . chapter 0 3 Ċ Ċ import Ġio . reactivex . Observable Ċ import Ġio . reactivex . subjects . Async Subject Ċ import Ġkotlinx . coroutines . experimental . delay Ċ import Ġkotlinx . coroutines . experimental . run Blocking Ċ import Ġjava . util . concurrent . TimeUnit Ċ Ċ /** Ċ Ġ* ĠCreated Ġby Ġ riv uc Ġon Ġ 2 2 - 0 7 - 2 0 1 7 . Ċ Ġ*/ Ċ Ċ fun Ġmain ( args : ĠArray < String >) Ġ{ ĊĠĠĠ Ġval Ġobservable Ġ= ĠObservable . just ( 1 , 2 , 3 , 4 )// 1 ĊĠĠĠ Ġval Ġsubject Ġ= ĠAsync Subject . create < Int >() // 2 ĊĠĠĠ Ġobservable . subscribe ( subject )// 3 ĊĠĠĠ Ġsubject . subscribe ({ // 4 ĊĠĠĠĠĠĠĠ Ġ// onNext ĊĠĠĠĠĠĠĠ Ġprintln (" Received Ġ$ it ") ĊĠĠĠ Ġ},{ ĊĠĠĠĠĠĠĠ Ġ// onError ĊĠĠĠĠĠĠĠ Ġit . printStackTrace () ĊĠĠĠ Ġ},{ ĊĠĠĠĠĠĠĠ Ġ// onComplete ĊĠĠĠĠĠĠĠ Ġprintln (" Complete ") ĊĠĠĠ Ġ}) ĊĠĠĠ Ġsubject . onNext ( 5 )// 5 ĊĠĠĠ Ġsubject . onComplete () // 6 Ċ }