def expectSettings: Receive = LoggingReceive.withLabel()

in core/src/main/scala/org/apache/pekko/kafka/internal/KafkaConsumerActor.scala [308:323]

• 13 lines of code
• 5 McCabe index (conditional complexity)

  def expectSettings: Receive = LoggingReceive.withLabel("expectSettings") {
    case s: ConsumerSettings[K @unchecked, V @unchecked] =>
      applySettings(s)

    case scala.util.Failure(e) =>
      owner.foreach(_ ! Failure(e))
      throw e

    case s: StopLike =>
      val from = stopFromMessage(s)
      log.debug("Received Stop from {}, stopping", from)
      context.stop(self)

    case _ =>
      stash()
  }