Method Detail

• StreamSerialProcessingQueue

   final static StreamSerialProcessingQueue StreamSerialProcessingQueue(StreamLogger logger, CoroutineScope scope, Boolean autoStart, CoroutineStart startMode, Integer capacity)

  Creates a new StreamSerialProcessingQueue instance.

  Parameters:

  logger - The logger to use for logging.

  scope - The coroutine scope to use for running the processor.

  autoStart - Whether to automatically start the processor when a job is submitted.

  startMode - The coroutine start mode to use when starting the processor.

  capacity - The capacity of the internal queue.