package Ġcom . task . note app . repository Ċ Ċ import Ġcom . task . note app . db . da os . Note Dao Ċ import Ġcom . task . note app . db . entities . Note Ċ import Ġkotlinx . coroutines . flow .* Ċ import Ġjavax . inject . Inject Ċ Ċ class ĠNote Local DataSource Ġ@ Inject Ġconstructor ( private Ġval Ġnote Dao : ĠNote Dao ) Ġ: ĠNote Repository Ġ{ ĊĊĠĠĠ Ġoverride Ġfun ĠgetAll Notes () Ġ= Ġflow Ġ{ ĊĠĠĠĠĠĠĠ Ġnote Dao . getAll () ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. de bounce ( 1 0 0 ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. distinct Until Changed () ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. collect Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġemit ( it ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġoverride Ġsuspend Ġfun Ġinsert All ( var arg Ġnotes : ĠNote ) Ġ{ ĊĠĠĠĠĠĠĠ Ġnote Dao . insert All (* notes ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġoverride Ġsuspend Ġfun Ġupdate ( note : ĠNote ) Ġ{ ĊĠĠĠĠĠĠĠ Ġnote Dao . update ( note ) ĊĠĠĠ Ġ} Ċ }