public void close()

in src/main/java/com/spotify/google/cloud/pubsub/client/Acker.java [204:213]

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

  public void close() throws IOException {
    // TODO (dano): fail outstanding futures
    scheduler.shutdownNow();
    try {
      scheduler.awaitTermination(30, SECONDS);
    } catch (InterruptedException e) {
      Thread.currentThread().interrupt();
    }
    pubsub.close();
  }