package Ġorg . k art b ah n . core Ċ Ċ import Ġio . ktor . utils . io . core .* Ċ import Ġkotlinx . coroutines .* Ċ import Ġkotlinx . coroutines . flow .* ĊĊ Ċ fun Ġ< T > ĠFlow < T >. as Common Flow (): ĠC Flow < T > Ġ= ĠC Flow ( this ) Ċ Ċ class ĠC Flow < T >( private Ġval Ġorigin : ĠFlow < T >) Ġ: ĠFlow < T > Ġby Ġorigin Ġ{ ĊĠĠĠ Ġfun Ġwatch ( block : Ġ( T ) Ġ-> ĠUnit ): ĠClose able Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġjob Ġ= ĠJob (/* Conference Service . coroutine Context [ Job ] */) ĊĊĠĠĠĠĠĠĠ Ġon Each Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġblock ( it ) ĊĠĠĠĠĠĠĠ Ġ}. launch In ( Coroutine Scope ( dispatcher () Ġ+ Ġjob )) ĊĊĠĠĠĠĠĠĠ Ġreturn Ġobject Ġ: ĠClose able Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġoverride Ġfun Ġclose () Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġjob . cancel () ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} Ċ }