override def toBinary()

in core/src/main/scala/org/apache/pekko/projection/internal/ProjectionSerializer.scala [63:71]

• 9 lines of code
• 7 McCabe index (conditional complexity)

  override def toBinary(o: AnyRef): Array[Byte] = o match {
    case m: GetOffset[_]     => getOffsetToBinary(m)
    case m: CurrentOffset[_] => currentOffsetToBinary(m)
    case m: SetOffset[_]     => setOffsetToBinary(m)
    case m: IsPaused         => isPausedToBinary(m)
    case m: SetPaused        => setPausedToBinary(m)
    case _ =>
      throw new IllegalArgumentException(s"Cannot serialize object of type [${o.getClass.getName}]")
  }