package Ġio . ash dav ies . rx . rx tasks Ċ Ċ import Ġcom . google . android . gms . tasks . On Complete Listener Ċ import Ġcom . google . android . gms . tasks . Task Ċ import Ġio . reactivex . Comp letable Emitter Ċ Ċ internal Ġclass ĠComp letable Emitter Listener ( private Ġval Ġemitter : ĠComp letable Emitter ) Ġ: ĠOn Complete Listener < Void > Ġ{ ĊĠ Ġoverride Ġfun ĠonComplete ( task : ĠTask < Void >) Ġ= Ġtry Ġ{ ĊĠĠĠ Ġtask . as Result () ĊĠĠĠ Ġemitter . onComplete () ĊĠ Ġ} Ġcatch Ġ( exception : ĠException ) Ġ{ ĊĠĠĠ Ġemitter . onError ( exception ) ĊĠ Ġ} Ċ } Ċ