Package 

Class StreamBatcherKt

    • Method Summary

      Modifier and Type Method Description
      final static <T extends Any> StreamBatcher<T> StreamBatcher(CoroutineScope scope, Integer batchSize, Long initialDelayMs, Long maxDelayMs, Boolean autoStart, Integer channelCapacity) Creates a new StreamBatcher instance.

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Method Detail

      • StreamBatcher

         final static <T extends Any> StreamBatcher<T> StreamBatcher(CoroutineScope scope, Integer batchSize, Long initialDelayMs, Long maxDelayMs, Boolean autoStart, Integer channelCapacity)

        Creates a new StreamBatcher instance.

        Parameters:
        scope - The coroutine scope.
        batchSize - The maximum number of items to be processed in a batch.
        initialDelayMs - The initial delay in milliseconds before processing a batch.
        maxDelayMs - The maximum delay in milliseconds before processing a batch.
        autoStart - Whether the processor should start automatically on the first enqueue.
        channelCapacity - The capacity of the underlying channel.