package Ġa de mar . bit ac . ext Ċ Ċ import Ġio . reactivex . rx java 3 . annotations . Check ReturnValue Ċ import Ġio . reactivex . rx java 3 . core . Comp letable Ċ import Ġio . reactivex . rx java 3 . core . Maybe Ċ import Ġio . reactivex . rx java 3 . core . Observable Ċ import Ġio . reactivex . rx java 3 . core . Single Ċ import Ġio . reactivex . rx java 3 . dis pos ables . Disposable Ċ Ċ /** Ċ Ġ* ĠGet Ġ ride Ġof ĠSAM Ġconversion Ġissues Ċ Ġ*/ Ċ Ċ @ Check ReturnValue Ċ fun Ġ< T > ĠObservable < T >. subscribe By ( ĊĠĠĠĠĠĠĠ Ġon Next : Ġ( T ) Ġ-> ĠUnit Ġ= Ġ{}, ĊĠĠĠĠĠĠĠ ĠonError : Ġ( Throwable ) Ġ-> ĠUnit Ġ= Ġ{ Ġerror Logger ( it ) Ġ}, ĊĠĠĠĠĠĠĠ ĠonComplete : Ġ() Ġ-> ĠUnit Ġ= Ġ{} Ċ ): ĠDis posable Ġ= Ġsubscribe ( onNext , ĠonError , ĠonComplete ) Ċ Ċ @ Check ReturnValue Ċ fun Ġ< T > ĠSingle < T >. subscribe By ( ĊĠĠĠĠĠĠĠ ĠonSuccess : Ġ( T ) Ġ-> ĠUnit Ġ= Ġ{}, ĊĠĠĠĠĠĠĠ ĠonError : Ġ( Throwable ) Ġ-> ĠUnit Ġ= Ġ{ Ġerror Logger ( it ) Ġ} Ċ ): ĠDis posable Ġ= Ġsubscribe ( on Success , ĠonError ) Ċ Ċ @ Check ReturnValue Ċ fun Ġ< T > ĠMaybe < T >. subscribe By ( ĊĠĠĠĠĠĠĠ ĠonSuccess : Ġ( T ) Ġ-> ĠUnit Ġ= Ġ{}, ĊĠĠĠĠĠĠĠ ĠonError : Ġ( Throwable ) Ġ-> ĠUnit Ġ= Ġ{ Ġerror Logger ( it ) Ġ} Ċ ): ĠDis posable Ġ= Ġsubscribe ( on Success , ĠonError ) Ċ Ċ @ Check ReturnValue Ċ fun ĠComp letable . subscribe By ( ĊĠĠĠĠĠĠĠ ĠonComplete : Ġ() Ġ-> ĠUnit Ġ= Ġ{}, ĊĠĠĠĠĠĠĠ ĠonError : Ġ( Throwable ) Ġ-> ĠUnit Ġ= Ġ{ Ġerror Logger ( it ) Ġ} Ċ ): ĠDis posable Ġ= Ġsubscribe ( onComplete , ĠonError ) Ċ