protected CancelableRunnable createFlusherRunnable()

in src/main/java/com/googlesource/gerrit/plugins/events/StreamEvents.java [130:146]

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

  protected CancelableRunnable createFlusherRunnable() {
    return new CancelableRunnable() {
      @Override
      public void run() {
        try {
          flushBatch();
        } catch (IOException e) {
          log.error("Error Flushing Stream Events", e);
        }
      }

      @Override
      public void cancel() {
        onExit(0);
      }
    };
  }