protected void startFlush()

in src/main/java/com/googlesource/gerrit/plugins/events/StreamEvents.java [161:167]

• 7 lines of code
• 4 McCabe index (conditional complexity)

  protected void startFlush() throws IOException {
    synchronized (crossThreadlock) {
      if (!isFlushing() && !shuttingDown && !isUpToDate()) {
        flusherTask = threadPool.submit(flusherRunnable);
      }
    }
  }