ktor-io/io.ktor.utils.io/LookAheadSuspendSession

LookAheadSuspendSession

~~interface~~ ~~LookAheadSuspendSession~~ : ~~LookAheadSession~~

Functions

abstract suspend fun awaitAtLeast(n: Int): Boolean

Suspend until n bytes become available or end of stream encountered (possibly due to exceptional close)

abstract fun consumed(n: Int)

Marks n bytes as consumed so the corresponding range becomes available for writing

abstract fun request(skip: Int, atLeast: Int): ByteBuffer?

Request byte buffer range skipping skip bytes and atLeast bytes length

Extensions

consumeEachRemaining

inline suspend fun LookAheadSuspendSession.consumeEachRemaining(visitor: suspend (ByteBuffer) -> Boolean)