/* Ċ Ġ* ĠMIT ĠLicense Ċ Ġ* Ċ Ġ* ĠCopyright Ġ( c ) Ġ 2 0 1 8 ĠJ oh an ĠF yll ing Ċ Ġ* ĠĊ Ġ* ĠPermission Ġis Ġhereby Ġgranted , Ġfree Ġof Ġcharge , Ġto Ġany Ġperson Ġobtaining Ġa Ġcopy Ċ Ġ* Ġof Ġthis Ġsoftware Ġand Ġassociated Ġdocumentation Ġfiles Ġ( the Ġ" Software "), Ġto Ġdeal Ċ Ġ* Ġin Ġthe ĠSoftware Ġwithout Ġrestriction , Ġincluding Ġwithout Ġlimitation Ġthe Ġrights Ċ Ġ* Ġto Ġuse , Ġcopy , Ġmodify , Ġmerge , Ġpublish , Ġdistribute , Ġsublicense , Ġand / or Ġsell Ċ Ġ* Ġcopies Ġof Ġthe ĠSoftware , Ġand Ġto Ġpermit Ġpersons Ġto Ġwhom Ġthe ĠSoftware Ġis Ċ Ġ* Ġfurnished Ġto Ġdo Ġso , Ġsubject Ġto Ġthe Ġfollowing Ġconditions : Ċ Ġ* Ċ Ġ* ĠThe Ġabove Ġcopyright Ġnotice Ġand Ġthis Ġpermission Ġnotice Ġshall Ġbe Ġincluded Ġin Ġall Ċ Ġ* Ġcopies Ġor Ġsubstantial Ġportions Ġof Ġthe ĠSoftware . Ċ Ġ* Ċ Ġ* ĠTHE ĠSOFTWARE ĠIS ĠPROVIDED Ġ" AS ĠIS ", ĠWITHOUT ĠWARRANTY ĠOF ĠANY ĠKIND , ĠEXPRESS ĠOR Ċ Ġ* ĠIMPLIED , ĠINCLUDING ĠBUT ĠNOT ĠLIMITED ĠTO ĠTHE ĠWARRANTIES ĠOF ĠMERCHANTABILITY , Ċ Ġ* ĠFITNESS ĠFOR ĠA ĠPARTICULAR ĠPURPOSE ĠAND ĠNONINFRINGEMENT . ĠIN ĠNO ĠEVENT ĠSHALL ĠTHE Ċ Ġ* ĠAUTHORS ĠOR ĠCOPYRIGHT ĠHOLDERS ĠBE ĠLIABLE ĠFOR ĠANY ĠCLAIM , ĠDAMAGES ĠOR ĠOTHER Ċ Ġ* ĠLIABILITY , ĠWHETHER ĠIN ĠAN ĠACTION ĠOF ĠCONTRACT , ĠTORT ĠOR ĠOTHERWISE , ĠARISING ĠFROM , Ċ Ġ* ĠOUT ĠOF ĠOR ĠIN ĠCONNECTION ĠWITH ĠTHE ĠSOFTWARE ĠOR ĠTHE ĠUSE ĠOR ĠOTHER ĠDEALINGS ĠIN ĠTHE Ċ Ġ* ĠSOFTWARE . Ċ Ġ*/ Ċ Ċ package Ġorg . auth lab . http . bodies Ċ Ċ import Ġjava . io . ByteArray OutputStream Ċ import Ġjava . nio . ByteBuffer Ċ import Ġkotlin . math . min Ċ Ċ class ĠByte Body ( val Ġbytes : ĠByteArray ) Ġ: ĠBody Ġ{ ĊĠĠĠ Ġoverride Ġval Ġwriter : ĠBody Writer ĊĠĠĠĠĠĠĠ Ġget () Ġ= ĠByte Body Writer ( bytes ) Ċ } Ċ Ċ abstract Ġclass ĠAbstract Byte Body Reader < out ĠB Ġ: ĠBody > Ġ: ĠAbstract Body Reader < B >() Ġ{ ĊĠĠĠ Ġprivate Ġvar Ġ_ buffer : ĠByteArrayOutputStream ? Ġ= Ġnull ĊĊĠĠĠ Ġoverride Ġfun Ġon Read Start ( content Length : ĠInt ?) Ġ{ ĊĠĠĠĠĠĠĠ Ġ_ buffer Ġ= ĠByteArrayOutputStream ( content Length Ġ?: Ġ 1 0 2 4 ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġoverride Ġfun Ġon Read Chunk ( buffer : ĠByteBuffer ) Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġinternal Buffer Ġ= Ġ_ buffer Ġ?: Ġthrow ĠIllegalStateException (" Internal Ġbuffer Ġnot Ġinitialized ") ĊĊĠĠĠĠĠĠĠ Ġwhile Ġ( buffer . has Remaining ()) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġinternal Buffer . write ( buffer . get (). toInt ()) ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġprotected Ġfun Ġget ByteArray Value (): ĠByteArray Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġinternal Buffer Ġ= Ġ_ buffer Ġ?: Ġthrow ĠIllegalStateException (" Internal Ġbuffer Ġnot Ġinitialized ") ĊĊĠĠĠĠĠĠĠ Ġreturn Ġinternal Buffer . toByteArray () ĊĠĠĠ Ġ} Ċ } Ċ Ċ class ĠByte Body Reader Ġ: ĠAbstract Byte Body Reader < Byte Body >() Ġ{ ĊĠĠĠ Ġoverride Ġfun Ġget Body () ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ= ĠByte Body ( get ByteArray Value ()) Ċ } Ċ Ċ open Ġclass ĠByte Body Writer ( val Ġbytes : ĠByteArray , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġoverride Ġval ĠcontentType : ĠString Ġ= Ġ" application / octet - stream ", ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġoverride Ġval Ġcontent Encoding : ĠString ? Ġ= Ġnull ) Ġ: ĠAbstract Body Writer () Ġ{ ĊĠĠĠ Ġprivate Ġvar Ġ_ position Ġ= Ġ 0 ĊĊĠĠĠ Ġoverride Ġval Ġcontent Length : ĠInt ? ĊĠĠĠĠĠĠĠ Ġget () Ġ= Ġbytes . size ĊĊĠĠĠ Ġoverride Ġfun Ġon Write Chunk ( buffer : ĠByteBuffer ): ĠBoolean Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġbytes To Write Ġ= Ġmin ( buffer . remaining (), Ġbytes . size ) ĊĠĠĠĠĠĠĠ Ġbuffer . put ( bytes , Ġ_ position , Ġbytes To Write ) ĊĠĠĠĠĠĠĠ Ġ_ position Ġ+= Ġbytes To Write ĊĠĠĠĠĠĠĠ Ġreturn Ġ_ position Ġ< Ġbytes . size ĊĠĠĠ Ġ} Ċ }