protected void subscribe()

in src/main/java/com/googlesource/gerrit/plugins/events/StreamEvents.java [192:205]

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

  protected void subscribe() {
    subscription =
        subscriptionListeners.add(pluginName,
            new StreamEventListener() {
              @Override
              public void onStreamEventUpdate() {
                try {
                  startFlush();
                } catch (IOException e) {
                  log.error("Error starting to flushing Stream Events", e);
                }
              }
            });
  }