public void close()

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

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

  public void close() {
    // TODO (dano): fail outstanding futures
    scheduler.shutdownNow();
    try {
      scheduler.awaitTermination(30, SECONDS);
    } catch (InterruptedException e) {
      Thread.currentThread().interrupt();
    }
    closeFuture.complete(null);
    listener.publisherClosed(Publisher.this);
  }