package Ġcom . sum era . arg allery . domain . base Ċ Ċ import Ġcom . sum era . arg allery . tools . log . Error Logger Ċ import Ġio . reactivex . Flow able Ċ import Ġio . reactivex . android . schedul ers . Android Schedulers Ċ import Ġio . reactivex . schedul ers . Schedulers Ċ Ċ abstract Ġclass ĠBase Flow abler < T > Ġ{ ĊĊĠĠĠ Ġabstract Ġprotected Ġfun Ġcreate (): ĠFlow able < T > ĊĊĠĠĠ Ġopen Ġfun Ġexecute (): ĠFlow able < T > Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn Ġcreate () ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. do OnError Ġ{ Ġe Ġ-> ĠError Logger . log ( e ) Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. subscribe On ( Schedulers . io ()) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. observe On ( Android Schedulers . main Thread ()) ĊĠĠĠ Ġ} Ċ } Ċ