private def cleanup()

in core/src/main/scala/org/apache/spark/eventhubs/client/EventHubsClient.scala [236:248]

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

  private def cleanup(): Unit = {
    pendingWorks.clear()

    if (partitionSender != null) {
      partitionSender.closeSync()
      partitionSender = null
    }

    if (_client != null) {
      ClientConnectionPool.returnClient(ehConf, _client)
      _client = null
    }
  }