def shutdown()

in src/main/scala/com/twitter/iago/feeder/ParrotFeeder.scala [85:99]

• 15 lines of code
• 3 McCabe index (conditional complexity)

  def shutdown(): Future[Unit] = {
    if (shuttingDown.updateIfEmpty(Return.Unit)) {
      try {
        log.trace("ParrotFeeder: shutting down ...")
        if (state == FeederState.RUNNING)
          state = FeederState.TIMEOUT // shuts down immediately when timeout
        cluster.shutdown()
        poller.shutdown()
        log.trace("ParrotFeeder: shut down")
      } finally {
        done.setDone()
      }
    }
    done
  }