Function jsonRpc

packages/effect/src/unstable/rpc/RpcSerialization.ts:181–206

(options?: {
  readonly contentType?: string | undefined
})

 * @since 4.0.0
 */
export const jsonRpc = (options?: {
  readonly contentType?: string | undefined
}): RpcSerialization["Service"] =>
  RpcSerialization.of({
    contentType: options?.contentType ?? "application/json",
    includesFraming: false,
    makeUnsafe: () => {
      const decoder = new TextDecoder()
      const batches = new Map<string | number, {
        readonly size: number
        readonly responses: Map<string | number, RpcMessage.FromServerEncoded>
      }>()
      return {
        decode: (bytes) => {
          const decoded: JsonRpcMessage | Array<JsonRpcMessage> = JSON.parse(
            typeof bytes === "string" ? bytes : decoder.decode(bytes)
          )
          return decodeJsonRpcRaw(decoded, batches)
        },
        encode: (response) => {
          const encoded = encodeJsonRpcResponse(response as any, batches)
          return encoded && JSON.stringify(encoded)
        }
      }
    }
  })

/**
 * Creates a newline-delimited JSON-RPC 2.0 serialization for RPC protocol