package Ġobservable s Ċ Ċ import Ġio . reactivex . Observable Ċ import Ġio . reactivex . rx kotlin . to Observable Ċ Ċ fun Ġmain () Ġ{ ĊĠĠĠ Ġval Ġobservable : ĠObservable < String > Ġ= ĠlistOf (" String Ġ 1 ", Ġ" String Ġ 2 ", Ġ" String Ġ 3 ", Ġ" String Ġ 4 "). to Observable () // 1 ĊĊĠĠĠ Ġobservable . subscribe ( ĊĠĠĠĠĠĠĠ Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġprintln (" Received Ġ$ it ") Ġ// Ġon Next ĊĠĠĠĠĠĠĠ Ġ}, ĊĠĠĠĠĠĠĠ Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġprintln (" Error Ġ${ it . message }") Ġ// ĠonError ĊĠĠĠĠĠĠĠ Ġ}, ĊĠĠĠĠĠĠĠ Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġprintln (" Done ") Ġ// ĠonComplete ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ) ĊĊĠĠĠ Ġobservable . subscribe ( ĊĠĠĠĠĠĠĠ Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġprintln (" Received Ġ$ it ") ĊĠĠĠĠĠĠĠ Ġ}, ĊĠĠĠĠĠĠĠ Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġprintln (" Error Ġ${ it . message }") ĊĠĠĠĠĠĠĠ Ġ}, ĊĠĠĠĠĠĠĠ Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġprintln (" Done ") ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ) Ċ }