public void destroy()

in src/main/java/com/googlesource/gerrit/plugins/events/StreamEvents.java [179:190]

• 12 lines of code
• 3 McCabe index (conditional complexity)

  public void destroy(ChannelSession channel) {
    unsubscribe();
    synchronized (crossThreadlock) {
      boolean alreadyShuttingDown = shuttingDown;
      shuttingDown = true;
      if (isFlushing()) {
        flusherTask.cancel(true);
      } else if (!alreadyShuttingDown) {
        onExit(0);
      }
    }
  }