ByteBufferAsyncProcessor

class ByteBufferAsyncProcessor(val id: String, val chunkSize: Int = DefaultChunkSize, val processor: (ByteBufferAsyncProcessor.Chunk) -> Unit)

Constructors

Link copied to clipboard
constructor(id: String, chunkSize: Int = DefaultChunkSize, processor: (ByteBufferAsyncProcessor.Chunk) -> Unit)

Types

Link copied to clipboard
class Chunk(chunkSize: Int)
Link copied to clipboard
object Companion
Link copied to clipboard

Properties

Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
val id: String
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard

Functions

Link copied to clipboard
fun acknowledge(seqn: Long)
Link copied to clipboard
fun clear()
Link copied to clipboard
fun pause(reason: String)
Link copied to clipboard
fun put(newData: ByteArray, offset: Int = 0, count: Int = newData.size)
Link copied to clipboard
Link copied to clipboard
fun resume(reason: String)
Link copied to clipboard
fun start()
Link copied to clipboard
fun stop(timeout: Duration = InfiniteDuration): Boolean
Link copied to clipboard
fun terminate(timeout: Duration = InfiniteDuration): Boolean