$unsafeAppend$
|
fun ByteReadPacket.$unsafeAppend$(builder: BytePacketBuilder): Unit |
afterHeadWrite
|
fun Output.afterHeadWrite(current: IoBuffer): Unit
fun Output.afterHeadWrite(current: ChunkBuffer): Unit |
completeReadHead
|
fun Input.completeReadHead(current: IoBuffer): Unit
fun Input.completeReadHead(current: ChunkBuffer): Unit |
decodeUTF8
|
fun IoBuffer.decodeUTF8(consumer: (Char) -> Boolean): Int fun Buffer.decodeUTF8(consumer: (Char) -> Boolean): Int
Decodes all the bytes to utf8 applying every character on consumer until or consumer return false .
If a consumer returned false then a character will be pushed back (including all surrogates will be pushed back as well)
and decodeUTF8 returns -1
|
decodeUTF8LineLoopSuspend
|
suspend fun decodeUTF8LineLoopSuspend(out: Appendable, limit: Int, nextChunk: suspend (Int) -> AbstractInput?): Boolean |
prepareReadFirstHead
|
fun Input.prepareReadFirstHead(minSize: Int): ChunkBuffer? |
prepareReadFirstHeadOld
|
fun Input.prepareReadFirstHeadOld(minSize: Int): IoBuffer? |
prepareReadNextHead
|
fun Input.prepareReadNextHead(current: ChunkBuffer): ChunkBuffer? |
prepareReadNextHeadOld
|
fun Input.prepareReadNextHeadOld(current: IoBuffer): IoBuffer? |
prepareWriteHead
|
fun Output.prepareWriteHead(capacity: Int, current: IoBuffer?): IoBuffer
fun Output.prepareWriteHead(capacity: Int, current: ChunkBuffer?): ChunkBuffer |