public void start()

in src/main/java/com/googlesource/gerrit/plugins/events/StreamEvents.java [106:128]

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

  public void start(ChannelSession channel, Environment env) throws IOException {
    try (DynamicOptions pluginOptions =
        new DynamicOptions(injector, dynamicBeans)) {
      try {
        parseCommandLine(pluginOptions);
      } catch (UnloggedFailure e) {
        String msg = e.getMessage();
        if (!msg.endsWith("\n")) {
          msg += "\n";
        }
        err.write(msg.getBytes("UTF-8"));
        err.flush();
        onExit(1);
        return;
      }
      stdout = toPrintWriter(out);

      initSent();
      flusherRunnable = createFlusherRunnable();
      subscribe();
      startFlush();
    }
  }