package Ġpl . wend igo . chrome Ċ Ċ import Ġio . reactivex . rx java 3 . core . Flow able Ċ import Ġio . reactivex . rx java 3 . core . Single Ċ Ċ type alias ĠSingle Block < T > Ġ= Ġ() Ġ-> ĠSingle < T > Ċ type alias ĠFlow able Block < T > Ġ= Ġ() Ġ-> ĠFlow able < T > Ċ Ċ fun Ġ< T > Ġsync ( block : ĠSingle Block < T >): ĠT Ġwhere ĠT Ġ: ĠAny Ġ{ ĊĠĠĠ Ġreturn Ġblock . invoke (). blocking Get () Ċ } Ċ Ċ fun Ġ< T > Ġsync ( single : ĠSingle < T >): ĠT Ġwhere ĠT Ġ: ĠAny Ġ{ ĊĠĠĠ Ġreturn Ġsingle . blocking Get () Ċ } Ċ Ċ fun Ġ< T > Ġawait Many ( block : ĠFlow able Block < T >): ĠList < T > Ġ{ ĊĠĠĠ Ġreturn Ġblock . invoke (). toList (). blocking Get () Ċ } Ċ Ċ fun Ġ< T > Ġon ( flow able : ĠFlow able < T >, Ġlistener : Ġ( T ) Ġ-> ĠUnit ) Ġ{ ĊĠĠĠ Ġflow able . subscribe ( listener ) Ċ } Ċ