package Ġcom . kafka . content . domain . recent Ċ Ċ import Ġcom . kafka . data . model . Subject Interactor Ċ import Ġcom . kafka . content . data . item . Item Repository Ċ import Ġcom . kafka . data . entities . Item With Recent Item Ċ import Ġcom . kafka . data . model . App Coroutine Dispatch ers Ċ import Ġkotlinx . coroutines . Coroutine Dispatcher Ċ import Ġkotlinx . coroutines . flow . Flow Ċ import Ġjavax . inject . Inject Ċ Ċ /** Ċ Ġ* ĠInter actor Ġfor Ġupdating Ġthe Ġhomepage . Ċ Ġ* Ġ*/ Ċ class ĠOb serve Recent Items Ġ@ Inject Ġconstructor ( ĊĠĠĠ Ġdispatch ers : ĠApp Coroutine Dispatch ers , ĊĠĠĠ Ġprivate Ġval Ġitem Repository : ĠItem Repository Ċ ) Ġ: ĠSubject Interactor < Unit , ĠList < Item With Recent Item >>() Ġ{ ĊĠĠĠ Ġoverride Ġval Ġdispatcher : ĠCor outine Dispatcher Ġ= Ġdispatch ers . io ĊĊĠĠĠ Ġoverride Ġfun Ġcreate Observable ( params : ĠUnit ): ĠFlow < List < Item With Recent Item >> Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn Ġitem Repository . observe Items With Recent ly Vis ited Info () ĊĠĠĠ Ġ} Ċ } Ċ