ByteBufferAsyncProcessor

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

Constructors

Link copied to clipboard
fun ByteBufferAsyncProcessor(    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
enum StateKind : Enum<ByteBufferAsyncProcessor.StateKind>

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
fun reprocessUnacknowledged()
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

Properties

Link copied to clipboard
var acknowledgedSeqn: Long = 0
Link copied to clipboard
var allDataProcessed: Boolean = true
Link copied to clipboard
val chunkCount: Int
Link copied to clipboard
val chunkSize: Int
Link copied to clipboard
val id: String
Link copied to clipboard
val processor: (ByteBufferAsyncProcessor.Chunk) -> Unit
Link copied to clipboard
var shrinkIntervalMs: Int
Link copied to clipboard
var state: ByteBufferAsyncProcessor.StateKind