ByteBufferAsyncProcessor

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