private def checkForCompletion()

in core/src/main/scala/org/apache/pekko/kafka/internal/DefaultProducerStage.scala [89:96]

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

  private def checkForCompletion(): Unit =
    if (isClosed(stage.in) && awaitingConfirmation == 0) {
      completionState match {
        case Some(Success(_))  => onCompletionSuccess()
        case Some(Failure(ex)) => onCompletionFailure(ex)
        case None              => failStage(new IllegalStateException("Stage completed, but there is no info about status"))
      }
    }