override def fromBinary()

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

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

  override def fromBinary(bytes: Array[Byte], manifest: String): AnyRef = manifest match {
    case GetOffsetManifest     => getOffsetFromBinary(bytes)
    case CurrentOffsetManifest => currentOffsetFromBinary(bytes)
    case SetOffsetManifest     => setOffsetFromBinary(bytes)
    case IsPausedManifest      => isPausedFromBinary(bytes)
    case SetPausedManifest     => setPausedFromBinary(bytes)
    case _ =>
      throw new NotSerializableException(
        s"Unimplemented deserialization of message with manifest [$manifest] in [${getClass.getName}]")
  }