package Ġcom . inl ac ou . ink kotlin commons . rx . observable s Ċ Ċ import Ġio . reactivex . rx java 3 . core . Single Ċ import Ġio . reactivex . rx java 3 . core . Single Emitter Ċ import Ġio . reactivex . rx java 3 . core . Single On Subscribe Ċ Ċ class ĠAny Obs Ġ< T > Ġprivate Ġconstructor ( private Ġval Ġwork : Ġ() Ġ-> ĠT ) Ġ: ĠSingle On Subscribe < T > Ġ{ ĊĠĠĊĠ Ġoverride Ġfun Ġsubscribe ( emitter : ĠSingle Emitter < T >) Ġ{ ĊĠĠĠ Ġemitter . on Success ( work . invoke ()) ĊĠ Ġ} ĊĠĠĊĠ Ġcompanion Ġobject Ġ{ ĊĠĠĠ Ġfun Ġ< T > Ġcreate ( work : Ġ() Ġ-> ĠT ): ĠSingle < T > Ġ{ ĊĠĠĠĠĠ Ġreturn ĠSingle . create ( Any Obs ( work )) ĊĠĠĠ Ġ} ĊĠ Ġ} Ċ }