Package io.ktor.utils.io.core.internal

Types

ChunkBuffer
Link copied to clipboard
common
open class ChunkBuffer(memory: Memory, origin: ChunkBuffer?, parentPool: ObjectPool<ChunkBuffer>?) : Buffer
DangerousInternalIoApi
Link copied to clipboard
common
annotation class DangerousInternalIoApi
API marked with this annotation is internal and extremely fragile and not intended to be used by library users.
MalformedUTF8InputException
Link copied to clipboard
common
class MalformedUTF8InputException(message: String) : Exception

Functions

$unsafeAppend$
Link copied to clipboard
common
fun ByteReadPacket.$unsafeAppend$(builder: BytePacketBuilder)
afterHeadWrite
Link copied to clipboard
common
fun Output.afterHeadWrite(current: IoBuffer)
fun Output.afterHeadWrite(current: ChunkBuffer)
completeReadHead
Link copied to clipboard
common
fun Input.completeReadHead(current: IoBuffer)
fun Input.completeReadHead(current: ChunkBuffer)
decodeUTF8
Link copied to clipboard
common
inline fun Buffer.decodeUTF8(consumer: (Char) -> Boolean): Int
Decodes all the bytes to utf8 applying every character on consumer until or consumer return false.
inline fun IoBuffer.decodeUTF8(consumer: (Char) -> Boolean): Int
decodeUTF8LineLoopSuspend
Link copied to clipboard
common
suspend fun decodeUTF8LineLoopSuspend(out: Appendable, limit: Int, nextChunk: suspend (Int) -> AbstractInput?): Boolean
prepareReadFirstHead
Link copied to clipboard
common
fun Input.prepareReadFirstHead(minSize: Int): ChunkBuffer?
prepareReadFirstHeadOld
Link copied to clipboard
common
@JvmName(name = prepareReadFirstHead)
fun Input.prepareReadFirstHeadOld(minSize: Int): IoBuffer?
prepareReadNextHead
Link copied to clipboard
common
fun Input.prepareReadNextHead(current: ChunkBuffer): ChunkBuffer?
prepareReadNextHeadOld
Link copied to clipboard
common
@JvmName(name = prepareReadNextHead)
fun Input.prepareReadNextHeadOld(current: IoBuffer): IoBuffer?
prepareWriteHead
Link copied to clipboard
common
fun Output.prepareWriteHead(capacity: Int, current: IoBuffer?): IoBuffer
fun Output.prepareWriteHead(capacity: Int, current: ChunkBuffer?): ChunkBuffer