interface LookAheadSuspendSession : LookAheadSession
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): Unit
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 |
suspend fun LookAheadSuspendSession.consumeEachRemaining(visitor: suspend (ByteBuffer) -> Boolean): Unit fun LookAheadSession.consumeEachRemaining(visitor: (ByteBuffer) -> Boolean): Unit |