/* Ċ Ġ* ĠCopyright Ġ 2 0 2 0 ĠOle ks and r ĠBe z ush ko Ċ Ġ* Ċ Ġ* ĠPermission Ġis Ġhereby Ġgranted , Ġfree Ġof Ġcharge , Ġto Ġany Ġperson Ġobtaining Ġa Ġcopy Ċ Ġ* Ġof Ġthis Ġsoftware Ġand Ġassociated Ġdocumentation Ġfiles Ġ( the Ġ" Software "), Ġto Ġdeal Ċ Ġ* Ġin Ġthe ĠSoftware Ġwithout Ġrestriction , Ġincluding Ġwithout Ġlimitation Ġthe Ġrights Ċ Ġ* Ġto Ġuse , Ġcopy , Ġmodify , Ġmerge , Ġpublish , Ġdistribute , Ġsublicense , Ġand / or Ġsell Ċ Ġ* Ġcopies Ġof Ġthe ĠSoftware , Ġand Ġto Ġpermit Ġpersons Ġto Ġwhom Ġthe ĠSoftware Ġis Ċ Ġ* Ġfurnished Ġto Ġdo Ġso , Ġsubject Ġto Ġthe Ġfollowing Ġconditions : Ċ Ġ* Ċ Ġ* ĠThe Ġabove Ġcopyright Ġnotice Ġand Ġthis Ġpermission Ġnotice Ġshall Ġbe Ġincluded Ġin Ġall Ċ Ġ* Ġcopies Ġor Ġsubstantial Ġportions Ġof Ġthe ĠSoftware . Ċ Ġ* Ċ Ġ* ĠTHE ĠSOFTWARE ĠIS ĠPROVIDED Ġ" AS ĠIS ", ĠWITHOUT ĠWARRANTY ĠOF ĠANY ĠKIND , ĠEXPRESS ĠOR Ċ Ġ* ĠIMPLIED , ĠINCLUDING ĠBUT ĠNOT ĠLIMITED ĠTO ĠTHE ĠWARRANTIES ĠOF ĠMERCHANTABILITY , Ċ Ġ* ĠFITNESS ĠFOR ĠA ĠPARTICULAR ĠPURPOSE ĠAND ĠNONINFRINGEMENT . ĠIN ĠNO ĠEVENT ĠSHALL ĠTHE Ċ Ġ* ĠAUTHORS ĠOR ĠCOPYRIGHT ĠHOLDERS ĠBE ĠLIABLE ĠFOR ĠANY ĠCLAIM , ĠDAMAGES ĠOR ĠOTHER Ċ Ġ* ĠLIABILITY , ĠWHETHER ĠIN ĠAN ĠACTION ĠOF ĠCONTRACT , ĠTORT ĠOR ĠOTHERWISE , ĠARISING ĠFROM , Ċ Ġ* ĠOUT ĠOF ĠOR ĠIN ĠCONNECTION ĠWITH ĠTHE ĠSOFTWARE ĠOR ĠTHE ĠUSE ĠOR ĠOTHER ĠDEALINGS ĠIN ĠTHE Ċ Ġ* ĠSOFTWARE . Ċ Ġ*/ Ċ Ċ package Ġcom . ins iders er . template . core . domain Ċ Ċ import Ġkotlinx . coroutines . Coroutine Dispatcher Ċ import Ġkotlinx . coroutines . channels . Con fl ated Broadcast Channel Ċ import Ġkotlinx . coroutines . flow . Flow Ċ import Ġkotlinx . coroutines . flow . as Flow Ċ import Ġkotlinx . coroutines . flow . distinct Until Changed Ċ import Ġkotlinx . coroutines . flow . flatMap Latest Ċ import Ġkotlinx . coroutines . flow . flow On Ċ import Ġkotlinx . coroutines . with Context Ċ Ċ abstract Ġclass ĠResult UseCase < in ĠParams , ĠType > Ġ{ ĊĊĠĠĠ Ġprotected Ġabstract Ġval Ġwork Dispatcher : ĠCor outine Dispatcher ĊĊĠĠĠ Ġsuspend Ġoperator Ġfun Ġinvoke ( param : ĠParams ): ĠResult < Type > Ġ= Ġwith Context ( work Dispatcher ) Ġ{ ĊĠĠĠĠĠĠĠ Ġexecute ( param ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġprotected Ġabstract Ġsuspend Ġfun Ġexecute ( param : ĠParams ): ĠResult < Type > Ċ } Ċ Ċ abstract Ġclass ĠNo Result UseCase < in ĠParams > Ġ{ ĊĊĠĠĠ Ġprotected Ġabstract Ġval Ġwork Dispatcher : ĠCor outine Dispatcher ĊĊĠĠĠ Ġsuspend Ġoperator Ġfun Ġinvoke ( param : ĠParams ) Ġ{ ĊĠĠĠĠĠĠĠ Ġwith Context ( work Dispatcher ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġexecute ( param ) ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġprotected Ġabstract Ġsuspend Ġfun Ġexecute ( param : ĠParams ) Ċ } Ċ Ċ abstract Ġclass ĠObservable UseCase < in ĠParam , ĠType > Ġ{ ĊĊĠĠĠ Ġprivate Ġval Ġevent Channel Ġ= ĠCon fl ated Broadcast Channel < Param >() ĊĊĠĠĠ Ġprotected Ġabstract Ġval Ġwork Dispatcher : ĠCor outine Dispatcher ĊĊĠĠĠ Ġoperator Ġfun Ġinvoke ( param : ĠParam ) Ġ{ ĊĠĠĠĠĠĠĠ Ġevent Channel . offer ( param ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġfun Ġobserve (): ĠFlow < Type > Ġ= Ġevent Channel . as Flow () ĊĠĠĠĠĠĠĠ Ġ. distinct Until Changed () ĊĠĠĠĠĠĠĠ Ġ. flatMap Latest Ġ{ Ġexecute ( it ) Ġ} ĊĠĠĠĠĠĠĠ Ġ. flow On ( work Dispatcher ) ĊĊĠĠĠ Ġprotected Ġabstract Ġsuspend Ġfun Ġexecute ( param : ĠParam ): ĠFlow < Type > Ċ } Ċ Ċ suspend Ġoperator Ġfun Ġ< Type > ĠResult UseCase < Unit , ĠType >. invoke (): ĠResult < Type > Ġ= Ġinvoke ( Unit ) Ċ suspend Ġoperator Ġfun ĠNo Result UseCase < Unit >. invoke () Ġ= Ġinvoke ( Unit ) Ċ operator Ġfun Ġ< Type > ĠObservable UseCase < Unit , ĠType >. invoke () Ġ= Ġinvoke ( Unit ) Ċ