public void flush()

in folsom/src/main/java/com/spotify/folsom/client/BatchFlusher.java [72:84]

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

  public void flush() {
    if (eventLoop.inEventLoop()) {
      pending++;
      if (pending >= maxPending) {
        pending = 0;
        channel.flush();
      }
    }
    if (woken == 0 && WOKEN.compareAndSet(this, 0, 1)) {
      woken = 1;
      eventLoop.execute(wakeup);
    }
  }