package Ġcom . bad oo . reak t ive . observable Ċ Ċ import Ġcom . bad oo . reak t ive . comp letable . Comp letable Ċ import Ġcom . bad oo . reak t ive . comp letable . Comp letable Callbacks Ċ import Ġcom . bad oo . reak t ive . comp letable . comp letable Ċ import Ġcom . bad oo . reak t ive . dis posable . Disposable Ċ Ċ fun ĠObservable <* >. as Comp letable (): ĠComp letable Ġ= ĊĠĠĠ Ġcomplet able Ġ{ Ġemitter Ġ-> ĊĠĠĠĠĠĠĠ Ġsubscribe ( ĊĠĠĠĠĠĠĠĠĠĠĠ Ġobject Ġ: ĠObservable Observer < Any ? >, ĠComp letable Callbacks Ġby Ġemitter Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġoverride Ġfun Ġon Subscribe ( dis posable : ĠDis posable ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġemitter . set Disposable ( dis posable ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġoverride Ġfun Ġon Next ( value : ĠAny ?) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ// Ġno - op ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠ Ġ) ĊĠĠĠ Ġ} Ċ