public void receiveAsync()

in src/main/java/com/googlesource/gerrit/plugins/kafka/api/KafkaBrokerApi.java [50:56]

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

  public void receiveAsync(String topic, Consumer<EventMessage> eventConsumer) {
    KafkaEventSubscriber subscriber = subscriberProvider.get();
    synchronized (subscribers) {
      subscribers.add(subscriber);
    }
    subscriber.subscribe(topic, eventConsumer);
  }