private void send()

in src/main/java/com/spotify/google/cloud/pubsub/client/Acker.java [134:148]

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

  private void send() {
    if (sending.compareAndSet(false, true)) {
      try {
        // Drain queue
        while (size.get() > 0 && outstanding.get() < concurrency) {
          final int sent = sendBatch();
          if (sent == 0) {
            return;
          }
        }
      } finally {
        sending.set(false);
      }
    }
  }