123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189
// Copyright 2018-2022 the Deno authors. All rights reserved. MIT license.// Copyright Joyent and Node contributors. All rights reserved. MIT license.// deno-lint-ignore-file
import { Buffer } from "../../buffer.ts";import { inspect } from "../util/inspect.mjs";
class BufferList {  constructor() {    this.head = null;    this.tail = null;    this.length = 0;  }
  push(v) {    const entry = { data: v, next: null };    if (this.length > 0) {      this.tail.next = entry;    } else {      this.head = entry;    }    this.tail = entry;    ++this.length;  }
  unshift(v) {    const entry = { data: v, next: this.head };    if (this.length === 0) {      this.tail = entry;    }    this.head = entry;    ++this.length;  }
  shift() {    if (this.length === 0) {      return;    }    const ret = this.head.data;    if (this.length === 1) {      this.head = this.tail = null;    } else {      this.head = this.head.next;    }    --this.length;    return ret;  }
  clear() {    this.head = this.tail = null;    this.length = 0;  }
  join(s) {    if (this.length === 0) {      return "";    }    let p = this.head;    let ret = "" + p.data;    while (p = p.next) {      ret += s + p.data;    }    return ret;  }
  concat(n) {    if (this.length === 0) {      return Buffer.alloc(0);    }    const ret = Buffer.allocUnsafe(n >>> 0);    let p = this.head;    let i = 0;    while (p) {      ret.set(p.data, i);      i += p.data.length;      p = p.next;    }    return ret;  }
  // Consumes a specified amount of bytes or characters from the buffered data.  consume(n, hasStrings) {    const data = this.head.data;    if (n < data.length) {      // `slice` is the same for buffers and strings.      const slice = data.slice(0, n);      this.head.data = data.slice(n);      return slice;    }    if (n === data.length) {      // First chunk is a perfect match.      return this.shift();    }    // Result spans more than one buffer.    return hasStrings ? this._getString(n) : this._getBuffer(n);  }
  first() {    return this.head.data;  }
  *[Symbol.iterator]() {    for (let p = this.head; p; p = p.next) {      yield p.data;    }  }
  // Consumes a specified amount of characters from the buffered data.  _getString(n) {    let ret = "";    let p = this.head;    let c = 0;    do {      const str = p.data;      if (n > str.length) {        ret += str;        n -= str.length;      } else {        if (n === str.length) {          ret += str;          ++c;          if (p.next) {            this.head = p.next;          } else {            this.head = this.tail = null;          }        } else {          ret += str.slice(0, n);          this.head = p;          p.data = str.slice(n);        }        break;      }      ++c;    } while (p = p.next);    this.length -= c;    return ret;  }
  // Consumes a specified amount of bytes from the buffered data.  _getBuffer(n) {    const ret = Buffer.allocUnsafe(n);    const retLen = n;    let p = this.head;    let c = 0;    do {      const buf = p.data;      if (n > buf.length) {        ret.set(buf, retLen - n);        n -= buf.length;      } else {        if (n === buf.length) {          ret.set(buf, retLen - n);          ++c;          if (p.next) {            this.head = p.next;          } else {            this.head = this.tail = null;          }        } else {          ret.set(            new Uint8Array(buf.buffer, buf.byteOffset, n),            retLen - n,          );          this.head = p;          p.data = buf.slice(n);        }        break;      }      ++c;    } while (p = p.next);    this.length -= c;    return ret;  }
  // Make sure the linked list only shows the minimal necessary information.  [inspect.custom](_, options) {    return inspect(this, {      ...options,      // Only inspect one level.      depth: 0,      // It should not recurse.      customInspect: false,    });  }}
export default BufferList;