package Ġcom . pix is . tr akt TV . views Ċ /* Ċ import Ġandroid . content . Context Ċ import Ġandroid . widget . Toast Ċ import Ġcom . pix is . tr akt TV . R Ċ import Ġio . reactivex . Observable Ċ import Ġio . realm . Realm Results Ċ import Ġio . realm . Realm ChangeListener Ċ import Ġio . reactivex . Observable Emitter Ċ import Ġio . realm . Realm Object Ċ import Ġio . reactivex . Observable On Subscribe Ċ import Ġio . realm . Realm Model ĊĊ Ċ object ĠUtils Ġ{ ĊĠĠĠ Ġfun Ġshow Error ( context : ĠContext ) Ġ{ ĊĠĠĠĠĠĠĠ Ġ// TODO Ġreplace Ġwith Ġsn ackbar ĊĠĠĠĠĠĠĠ ĠToast . makeText ( context , ĠR . string . error _ message , ĠToast . LENGTH _ SHORT ). show () ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġfun Ġshow Error ( context : ĠContext , Ġmessage : ĠString ) Ġ{ ĊĠĠĠĠĠĠĠ Ġ// TODO Ġreplace Ġwith Ġsn ackbar ĊĠĠĠĠĠĠĠ ĠToast . makeText ( context , Ġmessage , ĠToast . LENGTH _ SHORT ). show () ĊĠĠĠ Ġ} Ċ } Ċ Ċ // From Ġhttps :// gist . github . com / pat lo ew / 6 4 2 cf 5 9 5 b 1 4 3 cd 9 d 6 0 0 5 7 9 ca 9 8 8 b 6 1 6 a Ċ class ĠRealm Results Observable < T Ġ: ĠRealm Model >( private Ġval Ġrealm Results : ĠRealm Results < T >) Ġ: ĠObservable On Subscribe < Realm Results < T >> Ġ{ ĊĊĠĠĠ Ġoverride Ġfun Ġsubscribe ( emitter : ĠObservable Emitter < Realm Results < T >>) Ġ{ ĊĠĠĠĠĠĠĠ Ġ// ĠInitial Ġelement ĊĠĠĠĠĠĠĠ Ġemitter . onNext ( realm Results ) ĊĊĠĠĠĠĠĠĠ Ġval Ġchange Listener Ġ= ĠRealm ChangeListener < Realm Results < T >> Ġ{ Ġelement Ġ-> Ġemitter . onNext ( element ) Ġ} ĊĊĠĠĠĠĠĠĠ Ġrealm Results . add ChangeListener ( change Listener ) ĊĊĠĠĠĠĠĠĠ Ġemitter . set C ancellable { realm Results . remove ChangeListener ( change Listener )} ĊĠĠĠ Ġ} Ċ Ċ } Ċ fun Ġ< T Ġ: ĠRealm Model > ĠRealm Results < T >. as Observable 2 (): ĠObservable < Realm Results < T >> Ġ{ ĊĠĠĠ Ġreturn ĠObservable . create ( Realm Results Observable ( this )) Ċ }*/