def stopping: Receive = LoggingReceive.withLabel()

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

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

  def stopping: Receive = LoggingReceive.withLabel("stopping") {
    case p: Poll[_, _] =>
      receivePoll(p)
    case _: StopLike =>
    case Terminated(ref) =>
      stageActorsMap = stageActorsMap.filterNot(_._2 == ref)
    case _ @(_: Commit | _: RequestMessages) =>
      sender() ! Status.Failure(StoppingException())
    case msg @ (_: Assign | _: AssignWithOffset | _: Subscribe | _: SubscribePattern) =>
      log.warning("Got unexpected message {} when KafkaConsumerActor is in stopping state", msg)
  }