public ListenableFuture tryAppend()

in src/main/java/com/aliyun/openservices/aliyun/log/producer/internals/ProducerBatch.java [64:75]

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

  public ListenableFuture<Result> tryAppend(LogItem item, int sizeInBytes, Callback callback) {
    if (!hasRoomFor(sizeInBytes, 1)) {
      return null;
    } else {
      SettableFuture<Result> future = SettableFuture.create();
      logItems.add(item);
      thunks.add(new Thunk(callback, future));
      curBatchCount++;
      curBatchSizeInBytes += sizeInBytes;
      return future;
    }
  }