package Ġcom . ok ors un . contact sm ine . common Ċ Ċ import Ġrx . Observable Ċ Ċ /** Ċ Ġ* ĠCreated Ġby Ġok ors un Ġon Ġ 2 9 . 0 8 . 1 6 . Ċ Ġ*/ ĊĊ Ċ fun Ġ< T > Ġcreate Observable ( action : Ġ() Ġ-> ĠT ): ĠObservable < T > Ġ= ĊĠĠĠĠĠĠĠ ĠObservable . create ({ Ġsubscriber Ġ-> ĊĠĠĠĠĠĠĠĠĠĠĠ Ġtry Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġval Ġdata Ġ= Ġaction . invoke () ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġsubscriber . onNext ( data ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġsubscriber . on Completed () ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} Ġcatch Ġ( e : ĠException ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġsubscriber . onError ( e ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠ Ġ})