package Ġsk ed go . rx property Ċ Ċ import Ġandroidx . databinding . Observable Boolean Ċ import Ġrx . Observable Ċ import Ġrx . subscriptions . Subscriptions Ċ Ċ /** Ċ Ġ* ĠWhen Ġwe Ġsubscribe Ġto Ġan Ġ[ Observable ] Ġcreated Ġby Ġthis Ġfunction , Ċ Ġ* Ġthe Ġ[ Observable ] Ġwill Ġemit Ġthe Ġcurrent Ġvalue Ġof Ġ[ Observable Boolean ] Ċ Ġ* Ġand Ġalso Ġemit Ġany Ġfuture Ġchanges . Ċ Ġ*/ Ċ fun ĠObservable Boolean . as Observable (): ĠObservable < Boolean > Ġ{ ĊĠ Ġreturn ĠObservable . create Ġ{ ĊĠĠĠ Ġ// ĠTo Ġemit Ġthe Ġcurrent Ġvalue . ĊĠĠĠ Ġit . onNext ( get ()) ĊĠĠĠ Ġval Ġcallback Ġ= Ġobject Ġ: Ġandroidx . databinding . Observable . On PropertyChanged Callback () Ġ{ ĊĠĠĠĠĠ Ġoverride Ġfun Ġon PropertyChanged ( sender : Ġandroidx . databinding . Observable ?, Ġproperty Id : ĠInt ) Ġ{ ĊĠĠĠĠĠĠĠ Ġit . onNext ( get ()) ĊĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} ĊĠĠĠ Ġadd On PropertyChanged Callback ( callback ) ĊĠĠĠ Ġit . add ( Subscriptions . create Ġ{ Ġremove On PropertyChanged Callback ( callback ) Ġ}) ĊĠ Ġ} Ċ } Ċ