public List remainingBatches()

in src/main/java/com/aliyun/openservices/aliyun/log/producer/internals/RetryQueue.java [69:82]

• 14 lines of code
• 4 McCabe index (conditional complexity)

  public List<ProducerBatch> remainingBatches() {
    if (!closed) {
      throw new IllegalStateException(
          "cannot get the remaining batches before the retry queue closed");
    }
    while (true) {
      if (!putsInProgress()) {
        break;
      }
    }
    List<ProducerBatch> remainingBatches = new ArrayList<ProducerBatch>(retryBatches);
    retryBatches.clear();
    return remainingBatches;
  }