ListenableFuture publish()

in src/main/java/com/googlesource/gerrit/plugins/kinesis/KinesisPublisher.java [64:69]

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

  ListenableFuture<Boolean> publish(String streamName, Event event) {
    if (configuration.isSendAsync()) {
      return publishAsync(streamName, gson.toJson(event), event.getType());
    }
    return publishSync(streamName, gson.toJson(event), event.getType());
  }