Function decodeRequest

packages/cluster/src/internal/entityManager.ts:582–599

(
    message: Message.IncomingRequest<Rpcs>,
    rpc: Rpc.AnyWithProps
  )

  entityRpcs: Map<string, Rpcs>
) => {
  const decodeRequest = (
    message: Message.IncomingRequest<Rpcs>,
    rpc: Rpc.AnyWithProps
  ) => {
    const payload = Schema.decode(rpc.payloadSchema)(message.envelope.payload)
    const lastSentReply = Option.isSome(message.lastSentReply)
      ? Effect.asSome(Schema.decode(Reply.Reply(rpc as any))(message.lastSentReply.value))
      : Effect.succeedNone
    return Effect.flatMap(payload, (payload) =>
      Effect.map(lastSentReply, (lastSentReply) => ({
        _tag: "IncomingRequest" as const,
        envelope: {
          ...message.envelope,
          payload
        } as Envelope.Request.Any,
        lastSentReply
      })))
  }

  return (message: Message.Incoming<Rpcs>): Effect.Effect<
    {