public CompletableFuture publish()

in src/main/java/com/spotify/google/cloud/pubsub/client/Publisher.java [180:185]

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

  public CompletableFuture<String> publish(final String topic, final Message message) {
    final TopicQueue queue = topics.computeIfAbsent(topic, TopicQueue::new);
    final CompletableFuture<String> future = queue.send(message);
    listener.publishingMessage(this, topic, message, future);
    return future;
  }