package Ġpl . ipe bk . sets olver . remote Ċ Ċ import Ġio . reactivex . Single Emitter Ċ import Ġio . reactivex . Single On Subscribe Ċ import Ġorg . js oup . J soup Ċ import Ġorg . js oup . nodes . Document Ċ import Ġjava . io . IOException Ċ Ċ /** Ċ Ġ* ĠImplementation Ġof Ġ[ Single On Subscribe ] Ġthat Ġemits Ġresponse Ġ[ Document ] Ġfrom Ġgiven Ġurl Ċ Ġ*/ Ċ internal Ġclass ĠJ soup Simple On Subscribe ( private Ġval Ġurl : ĠString ) Ġ: ĠSingle On Subscribe < Document > Ġ{ ĊĠ Ġoverride Ġfun Ġsubscribe ( emitter : ĠSingle Emitter < Document >) Ġ{ ĊĠĠĠ Ġtry Ġ{ ĊĠĠĠĠĠ Ġval Ġresponse Ġ= ĠJ soup . connect ( url ). get () ĊĠĠĠĠĠ Ġif Ġ(! emitter . is Disposed ) ĊĠĠĠĠĠĠĠ Ġemitter . on Success ( response ) ĊĠĠĠ Ġ} Ġcatch Ġ( ex : ĠIOException ) Ġ{ ĊĠĠĠĠĠ Ġif Ġ(! emitter . is Disposed ) ĊĠĠĠĠĠĠĠ Ġemitter . onError ( ex ) ĊĠĠĠ Ġ} ĊĠ Ġ} Ċ }