package Ġrf id client Ċ Ċ import Ġio . netty . channel . Channel HandlerContext Ċ import Ġio . netty . channel . Simple Channel Inbound Handler Ċ import Ġkotlinx . coroutines . run Blocking Ċ Ċ class ĠChannel Handler ( ĊĠĠĠ Ġprivate Ġval Ġon R fid Received : Ġsuspend Ġ( rf id : ĠInt ) Ġ-> ĠUnit Ċ ) Ġ: ĠSimple Channel Inbound Handler < Int >() Ċ { ĊĠĠĠ Ġoverride Ġfun Ġchannel Read 0 ( ctx : ĠChannel HandlerContext ?, Ġrf id : ĠInt ) Ġ= Ġrun Blocking Ġ{ ĊĠĠĠĠĠĠĠ Ġon R fid Received ( rf id ) ĊĠĠĠ Ġ} Ċ }