StreamingFutureBatcher<T> constructor

StreamingFutureBatcher<T>(
  1. int threadCount
)

Implementation

StreamingFutureBatcher(int threadCount)
    : _closeWhenIdle = false,
      super(threadCount);