Function failMaxBufferSize

packages/effect/src/unstable/rpc/RpcSerialization.ts:125–128

(maxBufferSize: number)

      const decoder = new TextDecoder()
      let buffer = ""
      const failMaxBufferSize = (maxBufferSize: number): never => {
        buffer = ""
        throw new MaxBufferSizeExceeded({ maxBufferSize })
      }
      return ({
        decode: (bytes) => {
          buffer += typeof bytes === "string" ? bytes : decoder.decode(bytes, { stream: true })