Function parseBuffers

packages/pg-protocol/test/inbound-parser.test.ts:229–247

(
  buffers: ArrayBuffer[],
)

}

const parseBuffers = async (
  buffers: ArrayBuffer[],
): Promise<BackendMessage[]> => {
  const parser = new Parser()
  const msgs: BackendMessage[] = []
  const numBuffers = buffers.length

  await new Promise<void>((res) => {
    for (let i = 0; i < numBuffers; i++) {
      const buffer = buffers[i]
      parser.parse(buffer, (msg) => {
        msgs.push(msg)
        if (i === numBuffers - 1) res()
      })
    }
  })

  return msgs
}

function concatBuffers(views: ArrayBufferView[]): Uint8Array {
  let length = 0