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

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

Types

class Chunk(chunkSize: Int)

object Companion

enum StateKind : Enum<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

Properties

acknowledgedSeqn

var acknowledgedSeqn: Long = 0

allDataProcessed

var allDataProcessed: Boolean = true

val chunkCount: Int

val chunkSize: Int

val processor: (ByteBufferAsyncProcessor.Chunk) -> Unit

shrinkIntervalMs

var shrinkIntervalMs: Int

var state: ByteBufferAsyncProcessor.StateKind