package Ġcom . wallet connect . wallet connect v 2 . network . data . adapter Ċ Ċ import Ġcom . t inder . sc ar let . Stream Ċ import Ġcom . t inder . sc ar let . Stream Adapter Ċ import Ġcom . t inder . sc ar let . utils . getRaw Type Ċ import Ġkotlinx . coroutines . flow . Flow Ċ import Ġkotlinx . coroutines . flow . flow Ċ import Ġkotlinx . coroutines . reactive . collect Ċ import Ġjava . lang . reflect . Type Ċ Ċ internal Ġclass ĠFlow Stream Adapter < T > Ġ: ĠStream Adapter < T , ĠFlow < T >> Ġ{ ĊĠĠĠĠĊĠĠĠ Ġoverride Ġfun Ġadapt ( stream : ĠStream < T >) Ġ= Ġflow Ġ{ ĊĠĠĠĠĠĠĠ Ġstream . collect Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġemit ( it ) ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġinternal Ġclass ĠFactory Ġ: ĠStream Adapter . Factory Ġ{ ĊĊĠĠĠĠĠĠĠ Ġoverride Ġfun Ġcreate ( type : ĠType ): ĠStream Adapter < Any , ĠAny > Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġreturn Ġwhen Ġ( type . getRaw Type ()) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠFlow :: class . java Ġ-> ĠFlow Stream Adapter () ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġelse Ġ-> Ġthrow ĠIllegalArgumentException () ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} Ċ }