12345678910111213141516171819202122232425262728293031
export async function readMsg(reader: Deno.Reader): Promise<Uint8Array | null> {  const arr: Uint8Array[] = [];  const n = 100;  let readed: number | null;  while (true) {    const p: Uint8Array = new Uint8Array(n);    readed = await reader.read(p);    if (readed === null) break;    if (readed < n) {      arr.push(p.subarray(0, readed));      break;    } else {      arr.push(p);    }  }  if (readed === null) return readed;  const result = concatUint8Array(arr);  return result;}
export function concatUint8Array(arr: Uint8Array[]): Uint8Array {  const length = arr.reduce((pre, next) => pre + next.length, 0);  const result = new Uint8Array(length);  let offset = 0;  for (const v of arr) {    result.set(v, offset);    offset += v.length;  }  return result;}