2025.2.2-beta1

rd-core/com.jetbrains.rd.util.threading/ByteBufferAsyncProcessor

ByteBufferAsyncProcessor

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

Constructors

ByteBufferAsyncProcessor

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

Types

class Chunk(chunkSize: Int)

object Companion

enum StateKind : Enum<ByteBufferAsyncProcessor.StateKind>

Properties

acknowledgedSeqn

var acknowledgedSeqn: Long

allDataProcessed

var allDataProcessed: Boolean

val chunkCount: Int

val chunkSize: Int

val processor: (ByteBufferAsyncProcessor.Chunk) -> Unit

shrinkIntervalMs

var shrinkIntervalMs: Int

var state: ByteBufferAsyncProcessor.StateKind

Functions

fun acknowledge(seqn: Long)

fun clear()

fun pause(reason: String)

fun put(newData: ByteArray, offset: Int = 0, count: Int = newData.size)

reprocessUnacknowledged

fun reprocessUnacknowledged()

fun resume(reason: String)

fun start()

fun stop(timeout: Duration = InfiniteDuration): Boolean

fun terminate(timeout: Duration = InfiniteDuration): Boolean