public ListenableFuture append()

in src/main/java/com/aliyun/openservices/aliyun/log/producer/internals/LogAccumulator.java [73:88]

• 16 lines of code
• 1 McCabe index (conditional complexity)

  public ListenableFuture<Result> append(
      String project,
      String logStore,
      String topic,
      String source,
      String shardHash,
      List<LogItem> logItems,
      Callback callback)
      throws InterruptedException, ProducerException {
    appendsInProgress.incrementAndGet();
    try {
      return doAppend(project, logStore, topic, source, shardHash, logItems, callback);
    } finally {
      appendsInProgress.decrementAndGet();
    }
  }