package Ġcom . riv uch k . pack tp ub . reactive kotlin . chapter 0 3 Ċ Ċ import Ġio . reactivex . Observer Ċ import Ġio . reactivex . dis pos ables . Disposable Ċ import Ġio . reactivex . rx kotlin . to Observable Ċ Ċ /** Ċ Ġ* ĠCreated Ġby Ġ riv uc Ġon Ġ 2 2 - 0 7 - 2 0 1 7 . Ċ Ġ*/ Ċ Ċ fun Ġmain ( args : ĠArray < String >) Ġ{ ĊĊĠĠĠ Ġval Ġobserver : ĠObserver < Any > Ġ= Ġobject Ġ: Observer < Any >{ // 1 ĊĠĠĠĠĠĠĠ Ġoverride Ġfun ĠonComplete () Ġ{// 2 ĊĠĠĠĠĠĠĠĠĠĠĠ Ġprintln (" All ĠCompleted ") ĊĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠĠĠĠĠ Ġoverride Ġfun Ġon Next ( item : ĠAny ) Ġ{// 3 ĊĠĠĠĠĠĠĠĠĠĠĠ Ġprintln (" Next Ġ$ item ") ĊĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠĠĠĠĠ Ġoverride Ġfun ĠonError ( e : ĠThrowable ) Ġ{// 4 ĊĠĠĠĠĠĠĠĠĠĠĠ Ġprintln (" Error ĠOcc ured Ġ$ e ") ĊĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠĠĠĠĠ Ġoverride Ġfun Ġon Subscribe ( d : ĠDis posable ) Ġ{// 5 ĊĠĠĠĠĠĠĠĠĠĠĠ Ġprintln (" Sub scribed Ġto Ġ$ d ") ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġval Ġobservable : Ġio . reactivex . Observable < Any > Ġ= ĠlistOf (" One ", Ġ 2 , Ġ" Three ", Ġ" Four ", Ġ 4 . 5 , Ġ" Five ", Ġ 6 . 0 f ). to Observable () Ġ// 6 ĊĊĠĠĠ Ġobservable . subscribe ( observer )// 7 ĊĊĠĠĠ Ġval Ġobservable On List : Ġio . reactivex . Observable < List < Any >> Ġ= Ġio . reactivex . Observable . just ( listOf (" One ", Ġ 2 , Ġ" Three ", Ġ" Four ", Ġ 4 . 5 , Ġ" Five ", Ġ 6 . 0 f ), ĊĠĠĠĠĠĠĠĠĠĠĠ ĠlistOf (" List Ġwith ĠSingle ĠItem "), ĊĠĠĠĠĠĠĠĠĠĠĠ ĠlistOf ( 1 , 2 , 3 , 4 , 5 , 6 )) // 8 ĊĊĊĊĠĠĠ Ġobservable On List . subscribe ( observer )// 9 ĊĊ Ċ }