Function decode

packages/rpc/src/RpcSerialization.ts:370–390

(bytes)

      let incomplete: Uint8Array | undefined = undefined
      return {
        decode(bytes) {
          let buf = typeof bytes === "string" ? encoder.encode(bytes) : bytes
          if (incomplete !== undefined) {
            const prev = buf
            bytes = new Uint8Array(incomplete.length + buf.length)
            bytes.set(incomplete)
            bytes.set(prev, incomplete.length)
            buf = bytes
            incomplete = undefined
          }
          try {
            return unpackr.unpackMultiple(buf)
          } catch (error_) {
            const error = error_ as any
            if (error.incomplete) {
              incomplete = buf.subarray(error.lastPosition)
              return error.values ?? []
            }
            throw error_
          }
        },
        encode: (response) => packr.pack(response)
      }
    }