private void submitIncompleteBatches()

in src/main/java/com/aliyun/openservices/aliyun/log/producer/internals/Mover.java [106:110]

• 5 lines of code
• 2 McCabe index (conditional complexity)

  private void submitIncompleteBatches(List<ProducerBatch> incompleteBatches) {
    for (ProducerBatch b : incompleteBatches) {
      ioThreadPool.submit(createSendProducerBatchTask(b));
    }
  }