def deserializer = Serializer()

in codegen/src/main/scala/org/apache/pekko/grpc/gen/javadsl/Method.scala [36:57]

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

  def deserializer = Serializer(method, inputType)
  def serializer = Serializer(method, outputType)

  def unmarshal =
    if (inputStreaming) "GrpcMarshalling.unmarshalStream"
    else "GrpcMarshalling.unmarshal"

  def marshal =
    if (outputStreaming) "GrpcMarshalling.marshalStream"
    else "GrpcMarshalling.marshal"

  def inputTypeUnboxed = getMessageType(inputType)
  def outputTypeUnboxed = getMessageType(outputType)

  val methodType: MethodType = {
    (inputStreaming, outputStreaming) match {
      case (false, false) => Unary
      case (true, false)  => ClientStreaming
      case (false, true)  => ServerStreaming
      case (true, true)   => BidiStreaming
    }
  }