package Ġcom . example . rx jav ast udy . from Ċ Ċ import Ġandroid . util . Log Ċ import Ġcom . example . rx jav ast udy . constant . Constants Ċ import Ġio . reactivex . Observable Ċ import Ġio . reactivex . Observer Ċ import Ġio . reactivex . dis pos ables . Disposable Ċ Ċ fun Ġfrom Array () Ġ{ ĊĠĠĠ Ġval Ġevents : ĠArray < String > Ġ= ĠarrayOf (" 1 ", Ġ" 2 ", Ġ" 3 ") ĊĠĠĠ ĠObservable . from Array (* events ) ĊĠĠĠĠĠĠĠ Ġ. subscribe ( object Ġ: ĠObserver < String > Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġoverride Ġfun Ġon Subscribe ( d : ĠDis posable ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠLog . d ( Constants . TAG , Ġ" on Subscribe : Ġ") ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠĠĠĠĠĠĠĠĠ Ġoverride Ġfun Ġon Next ( t : ĠString ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠLog . d ( Constants . TAG , Ġ" onNext : Ġvalue Ġ= Ġ$ t ") ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠĠĠĠĠĠĠĠĠ Ġoverride Ġfun ĠonError ( e : ĠThrowable ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠLog . d ( Constants . TAG , Ġ" onError : Ġ") ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠĠĠĠĠĠĠĠĠ Ġoverride Ġfun ĠonComplete () Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠLog . d ( Constants . TAG , Ġ" onComplete : Ġ") ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠ Ġ}) Ċ }