protected void flushBatch()

in src/main/java/com/googlesource/gerrit/plugins/events/StreamEvents.java [214:232]

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

  protected void flushBatch() throws IOException {
    String uuid = events.getUuid().toString();
    int processed = 0;
    while (!isUpToDate() && processed < BATCH_SIZE) {
      long sending = sent + 1;
      String event = events.get(sending);
      if (Thread.interrupted() || stdout.checkError()) {
        onExit(0);
        return;
      }
      flush(uuid, sending, event);
      sent = sending;
      processed++;
    }
    synchronized (crossThreadlock) {
      flusherTask = null;
    }
    startFlush();
  }