package Ġio . ktor . utils . io Ċ Ċ import Ġio . ktor . utils . io . core .* Ċ import Ġjava . nio .* Ċ Ċ /** Ċ Ġ* ĠCreates Ġchannel Ġfor Ġreading Ġfrom Ġthe Ġspecified Ġbyte Ġbuffer . Ċ Ġ*/ Ċ public Ġfun ĠByte Read Channel ( content : ĠByteBuffer ): ĠByte Read Channel Ġ= ĠByteBuffer Channel ( content ) Ċ Ċ /** Ċ Ġ* ĠCreates Ġbuffered Ġchannel Ġfor Ġasynchronous Ġreading Ġand Ġwriting Ġof Ġsequences Ġof Ġbytes . Ċ Ġ*/ Ċ public Ġactual Ġfun ĠByte Channel ( auto Flush : ĠBoolean ): ĠByte Channel Ġ= ĠByteBuffer Channel ( auto Flush Ġ= Ġauto Flush ) Ċ Ċ /** Ċ Ġ* ĠCreates Ġchannel Ġfor Ġreading Ġfrom Ġthe Ġspecified Ġbyte Ġarray . Ċ Ġ*/ Ċ public Ġactual Ġfun ĠByte Read Channel ( content : ĠByteArray , Ġoffset : ĠInt , Ġlength : ĠInt ): ĠByte Read Channel Ġ= ĊĠĠĠ ĠByteBuffer Channel ( ByteBuffer . wrap ( content , Ġoffset , Ġlength )) Ċ Ċ /** Ċ Ġ* ĠCreates Ġbuffered Ġchannel Ġfor Ġasynchronous Ġreading Ġand Ġwriting Ġof Ġsequences Ġof Ġbytes Ġusing Ġ[ close ] Ġfunction Ġto Ġclose Ċ Ġ* Ġchannel . Ċ Ġ*/ Ċ @ Experimental Io Api Ċ public Ġfun ĠByte Channel ( auto Flush : ĠBoolean Ġ= Ġfalse , Ġexception Mapper : Ġ( Throwable ?) Ġ-> ĠThrowable ?): ĠByte Channel Ġ= ĊĠĠĠ Ġobject Ġ: ĠByteBuffer Channel ( auto Flush Ġ= Ġauto Flush ) Ġ{ ĊĊĠĠĠĠĠĠĠ Ġoverride Ġfun Ġclose ( cause : ĠThrowable ?): ĠBoolean Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġval Ġmapped Exception Ġ= Ġexception Mapper ( cause ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġreturn Ġsuper . close ( mapped Exception ) ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} Ċ