it-pushable - npm Package Compare versions

Comparing version 3.2.3 to 3.2.4

dist/index.min.js.map

+{
+  "version": 3,
+  "sources": ["../src/index.ts", "../node_modules/p-defer/index.js", "../src/fifo.ts"],
+  "sourcesContent": ["/**\n * @packageDocumentation\n *\n * An iterable that you can push values into.\n *\n * @example\n *\n * ```js\n * import { pushable } from 'it-pushable'\n *\n * const source = pushable()\n *\n * setTimeout(() => source.push('hello'), 100)\n * setTimeout(() => source.push('world'), 200)\n * setTimeout(() => source.end(), 300)\n *\n * const start = Date.now()\n *\n * for await (const value of source) {\n *   console.log(`got \"${value}\" after ${Date.now() - start}ms`)\n * }\n * console.log(`done after ${Date.now() - start}ms`)\n *\n * // Output:\n * // got \"hello\" after 105ms\n * // got \"world\" after 207ms\n * // done after 309ms\n * ```\n *\n * @example\n *\n * ```js\n * import { pushableV } from 'it-pushable'\n * import all from 'it-all'\n *\n * const source = pushableV()\n *\n * source.push(1)\n * source.push(2)\n * source.push(3)\n * source.end()\n *\n * console.info(await all(source))\n *\n * // Output:\n * // [ [1, 2, 3] ]\n * ```\n */\n\nimport deferred from 'p-defer'\nimport { FIFO } from './fifo.ts'\nimport type { Next } from './fifo.ts'\n\nexport class AbortError extends Error {\n  type: string\n  code: string\n\n  constructor (message?: string, code?: string) {\n    super(message ?? 'The operation was aborted')\n    this.type = 'aborted'\n    this.code = code ?? 'ABORT_ERR'\n  }\n}\n\nexport interface AbortOptions {\n  signal?: AbortSignal\n}\n\ninterface BasePushable<T> {\n  /**\n   * End the iterable after all values in the buffer (if any) have been yielded. If an\n   * error is passed the buffer is cleared immediately and the next iteration will\n   * throw the passed error\n   */\n  end(err?: Error): this\n\n  /**\n   * Push a value into the iterable. Values are yielded from the iterable in the order\n   * they are pushed. Values not yet consumed from the iterable are buffered.\n   */\n  push(value: T): this\n\n  /**\n   * Returns a promise that resolves when the underlying queue becomes empty (e.g.\n   * this.readableLength === 0).\n   *\n   * If an AbortSignal is passed as an option and that signal aborts, it only\n   * causes the returned promise to reject - it does not end the pushable.\n   */\n  onEmpty(options?: AbortOptions): Promise<void>\n\n  /**\n   * This property contains the number of bytes (or objects) in the queue ready to be read.\n   *\n   * If `objectMode` is true, this is the number of objects in the queue, if false it's the\n   * total number of bytes in the queue.\n   */\n  readableLength: number\n}\n\n/**\n * An iterable that you can push values into.\n */\nexport interface Pushable<T, R = void, N = unknown> extends AsyncGenerator<T, R, N>, BasePushable<T> {}\n\n/**\n * Similar to `pushable`, except it yields multiple buffered chunks at a time. All values yielded from the iterable will be arrays.\n */\nexport interface PushableV<T, R = void, N = unknown> extends AsyncGenerator<T[], R, N>, BasePushable<T> {}\n\nexport interface Options {\n  /**\n   * A boolean value that means non-`Uint8Array`s will be passed to `.push`, default: `false`\n   */\n  objectMode?: boolean\n\n  /**\n   * A function called after *all* values have been yielded from the iterator (including\n   * buffered values). In the case when the iterator is ended with an error it will be\n   * passed the error as a parameter.\n   */\n  onEnd?(err?: Error): void\n}\n\nexport interface DoneResult { done: true }\nexport interface ValueResult<T> { done: false, value: T }\nexport type NextResult<T> = ValueResult<T> | DoneResult\n\ninterface getNext<T, V = T> { (buffer: FIFO<T>): NextResult<V> }\n\nexport interface ObjectPushableOptions extends Options {\n  objectMode: true\n}\n\nexport interface BytePushableOptions extends Options {\n  objectMode?: false\n}\n\n/**\n * Create a new async iterable. The values yielded from calls to `.next()`\n * or when used in a `for await of`loop are \"pushed\" into the iterable.\n * Returns an async iterable object with additional methods.\n */\nexport function pushable<T extends { byteLength: number } = Uint8Array> (options?: BytePushableOptions): Pushable<T>\nexport function pushable<T> (options: ObjectPushableOptions): Pushable<T>\nexport function pushable<T> (options: Options = {}): Pushable<T> {\n  const getNext = (buffer: FIFO<T>): NextResult<T> => {\n    const next: Next<T> | undefined = buffer.shift()\n\n    if (next == null) {\n      return { done: true }\n    }\n\n    if (next.error != null) {\n      throw next.error\n    }\n\n    return {\n      done: next.done === true,\n      // @ts-expect-error if done is false, value will be present\n      value: next.value\n    }\n  }\n\n  return _pushable<T, T, Pushable<T>>(getNext, options)\n}\n\nexport function pushableV<T extends { byteLength: number } = Uint8Array> (options?: BytePushableOptions): PushableV<T>\nexport function pushableV<T> (options: ObjectPushableOptions): PushableV<T>\nexport function pushableV<T> (options: Options = {}): PushableV<T> {\n  const getNext = (buffer: FIFO<T>): NextResult<T[]> => {\n    let next: Next<T> | undefined\n    const values: T[] = []\n\n    while (!buffer.isEmpty()) {\n      next = buffer.shift()\n\n      if (next == null) {\n        break\n      }\n\n      if (next.error != null) {\n        throw next.error\n      }\n\n      if (next.done === false) {\n        // @ts-expect-error if done is false value should be pushed\n        values.push(next.value)\n      }\n    }\n\n    if (next == null) {\n      return { done: true }\n    }\n\n    return {\n      done: next.done === true,\n      value: values\n    }\n  }\n\n  return _pushable<T, T[], PushableV<T>>(getNext, options)\n}\n\nfunction _pushable<PushType, ValueType, ReturnType> (getNext: getNext<PushType, ValueType>, options?: Options): ReturnType {\n  options = options ?? {}\n  let onEnd = options.onEnd\n  let buffer = new FIFO<PushType>()\n  let pushable: any\n  let onNext: ((next: Next<PushType>) => ReturnType) | null\n  let ended: boolean\n  let drain = deferred()\n\n  const waitNext = async (): Promise<NextResult<ValueType>> => {\n    try {\n      if (!buffer.isEmpty()) {\n        return getNext(buffer)\n      }\n\n      if (ended) {\n        return { done: true }\n      }\n\n      return await new Promise<NextResult<ValueType>>((resolve, reject) => {\n        onNext = (next: Next<PushType>) => {\n          onNext = null\n          buffer.push(next)\n\n          try {\n            resolve(getNext(buffer))\n          } catch (err) {\n            reject(err)\n          }\n\n          return pushable\n        }\n      })\n    } finally {\n      if (buffer.isEmpty()) {\n        // settle promise in the microtask queue to give consumers a chance to\n        // await after calling .push\n        queueMicrotask(() => {\n          drain.resolve()\n          drain = deferred()\n        })\n      }\n    }\n  }\n\n  const bufferNext = (next: Next<PushType>): ReturnType => {\n    if (onNext != null) {\n      return onNext(next)\n    }\n\n    buffer.push(next)\n    return pushable\n  }\n\n  const bufferError = (err: Error): ReturnType => {\n    buffer = new FIFO()\n\n    if (onNext != null) {\n      return onNext({ error: err })\n    }\n\n    buffer.push({ error: err })\n    return pushable\n  }\n\n  const push = (value: PushType): ReturnType => {\n    if (ended) {\n      return pushable\n    }\n\n    // @ts-expect-error `byteLength` is not declared on PushType\n    if (options?.objectMode !== true && value?.byteLength == null) {\n      throw new Error('objectMode was not true but tried to push non-Uint8Array value')\n    }\n\n    return bufferNext({ done: false, value })\n  }\n  const end = (err?: Error): ReturnType => {\n    if (ended) { return pushable }\n    ended = true\n\n    return (err != null) ? bufferError(err) : bufferNext({ done: true })\n  }\n  const _return = (): DoneResult => {\n    buffer = new FIFO()\n    end()\n\n    return { done: true }\n  }\n  const _throw = (err: Error): DoneResult => {\n    end(err)\n\n    return { done: true }\n  }\n\n  pushable = {\n    [Symbol.asyncIterator] () { return this },\n    next: waitNext,\n    return: _return,\n    throw: _throw,\n    push,\n    end,\n    get readableLength (): number {\n      return buffer.size\n    },\n    onEmpty: async (options?: AbortOptions) => {\n      const signal = options?.signal\n      signal?.throwIfAborted()\n\n      if (buffer.isEmpty()) {\n        return\n      }\n\n      let cancel: Promise<void> | undefined\n      let listener: (() => void) | undefined\n\n      if (signal != null) {\n        cancel = new Promise((resolve, reject) => {\n          listener = () => {\n            reject(new AbortError())\n          }\n\n          signal.addEventListener('abort', listener)\n        })\n      }\n\n      try {\n        await Promise.race([\n          drain.promise,\n          cancel\n        ])\n      } finally {\n        if (listener != null && signal != null) {\n          signal?.removeEventListener('abort', listener)\n        }\n      }\n    }\n  }\n\n  if (onEnd == null) {\n    return pushable\n  }\n\n  const _pushable = pushable\n\n  pushable = {\n    [Symbol.asyncIterator] () { return this },\n    next () {\n      return _pushable.next()\n    },\n    throw (err: Error) {\n      _pushable.throw(err)\n\n      if (onEnd != null) {\n        onEnd(err)\n        onEnd = undefined\n      }\n\n      return { done: true }\n    },\n    return () {\n      _pushable.return()\n\n      if (onEnd != null) {\n        onEnd()\n        onEnd = undefined\n      }\n\n      return { done: true }\n    },\n    push,\n    end (err: Error) {\n      _pushable.end(err)\n\n      if (onEnd != null) {\n        onEnd(err)\n        onEnd = undefined\n      }\n\n      return pushable\n    },\n    get readableLength () {\n      return _pushable.readableLength\n    },\n    onEmpty: (opts?: AbortOptions) => {\n      return _pushable.onEmpty(opts)\n    }\n  }\n\n  return pushable\n}\n", "export default function pDefer() {\n\tconst deferred = {};\n\n\tdeferred.promise = new Promise((resolve, reject) => {\n\t\tdeferred.resolve = resolve;\n\t\tdeferred.reject = reject;\n\t});\n\n\treturn deferred;\n}\n", "// ported from https://www.npmjs.com/package/fast-fifo\n\nexport interface Next<T> {\n  done?: boolean\n  error?: Error\n  value?: T\n}\n\nclass FixedFIFO<T> {\n  public buffer: Array<Next<T> | undefined>\n  private readonly mask: number\n  private top: number\n  private btm: number\n  public next: FixedFIFO<T> | null\n\n  constructor (hwm: number) {\n    if (!(hwm > 0) || ((hwm - 1) & hwm) !== 0) {\n      throw new Error('Max size for a FixedFIFO should be a power of two')\n    }\n\n    this.buffer = new Array(hwm)\n    this.mask = hwm - 1\n    this.top = 0\n    this.btm = 0\n    this.next = null\n  }\n\n  push (data: Next<T>): boolean {\n    if (this.buffer[this.top] !== undefined) {\n      return false\n    }\n\n    this.buffer[this.top] = data\n    this.top = (this.top + 1) & this.mask\n\n    return true\n  }\n\n  shift (): Next<T> | undefined {\n    const last = this.buffer[this.btm]\n\n    if (last === undefined) {\n      return undefined\n    }\n\n    this.buffer[this.btm] = undefined\n    this.btm = (this.btm + 1) & this.mask\n    return last\n  }\n\n  isEmpty (): boolean {\n    return this.buffer[this.btm] === undefined\n  }\n}\n\nexport interface FIFOOptions {\n  /**\n   * When the queue reaches this size, it will be split into head/tail parts\n   */\n  splitLimit?: number\n}\n\nexport class FIFO<T> {\n  public size: number\n  private readonly hwm: number\n  private head: FixedFIFO<T>\n  private tail: FixedFIFO<T>\n\n  constructor (options: FIFOOptions = {}) {\n    this.hwm = options.splitLimit ?? 16\n    this.head = new FixedFIFO<T>(this.hwm)\n    this.tail = this.head\n    this.size = 0\n  }\n\n  calculateSize (obj: any): number {\n    if (obj?.byteLength != null) {\n      return obj.byteLength\n    }\n\n    return 1\n  }\n\n  push (val: Next<T>): void {\n    if (val?.value != null) {\n      this.size += this.calculateSize(val.value)\n    }\n\n    if (!this.head.push(val)) {\n      const prev = this.head\n      this.head = prev.next = new FixedFIFO<T>(2 * this.head.buffer.length)\n      this.head.push(val)\n    }\n  }\n\n  shift (): Next<T> | undefined {\n    let val = this.tail.shift()\n\n    if (val === undefined && (this.tail.next != null)) {\n      const next = this.tail.next\n      this.tail.next = null\n      this.tail = next\n      val = this.tail.shift()\n    }\n\n    if (val?.value != null) {\n      this.size -= this.calculateSize(val.value)\n    }\n\n    return val\n  }\n\n  isEmpty (): boolean {\n    return this.head.isEmpty()\n  }\n}\n"],
+  "mappings": ";8bAAA,IAAAA,EAAA,GAAAC,EAAAD,EAAA,gBAAAE,EAAA,aAAAC,EAAA,cAAAC,ICAe,SAARC,GAA0B,CAChC,IAAMC,EAAW,CAAC,EAElB,OAAAA,EAAS,QAAU,IAAI,QAAQ,CAACC,EAASC,IAAW,CACnDF,EAAS,QAAUC,EACnBD,EAAS,OAASE,CACnB,CAAC,EAEMF,CACR,CCDA,IAAMG,EAAN,KAAe,CACN,OACU,KACT,IACA,IACD,KAEP,YAAaC,EAAW,CACtB,GAAI,EAAEA,EAAM,KAAQA,EAAM,EAAKA,KAAS,EACtC,MAAM,IAAI,MAAM,mDAAmD,EAGrE,KAAK,OAAS,IAAI,MAAMA,CAAG,EAC3B,KAAK,KAAOA,EAAM,EAClB,KAAK,IAAM,EACX,KAAK,IAAM,EACX,KAAK,KAAO,IACd,CAEA,KAAMC,EAAa,CACjB,OAAI,KAAK,OAAO,KAAK,GAAG,IAAM,OACrB,IAGT,KAAK,OAAO,KAAK,GAAG,EAAIA,EACxB,KAAK,IAAO,KAAK,IAAM,EAAK,KAAK,KAE1B,GACT,CAEA,OAAK,CACH,IAAMC,EAAO,KAAK,OAAO,KAAK,GAAG,EAEjC,GAAIA,IAAS,OAIb,YAAK,OAAO,KAAK,GAAG,EAAI,OACxB,KAAK,IAAO,KAAK,IAAM,EAAK,KAAK,KAC1BA,CACT,CAEA,SAAO,CACL,OAAO,KAAK,OAAO,KAAK,GAAG,IAAM,MACnC,GAUWC,EAAP,KAAW,CACR,KACU,IACT,KACA,KAER,YAAaC,EAAuB,CAAA,EAAE,CACpC,KAAK,IAAMA,EAAQ,YAAc,GACjC,KAAK,KAAO,IAAIL,EAAa,KAAK,GAAG,EACrC,KAAK,KAAO,KAAK,KACjB,KAAK,KAAO,CACd,CAEA,cAAeM,EAAQ,CACrB,OAAIA,GAAK,YAAc,KACdA,EAAI,WAGN,CACT,CAEA,KAAMC,EAAY,CAKhB,GAJIA,GAAK,OAAS,OAChB,KAAK,MAAQ,KAAK,cAAcA,EAAI,KAAK,GAGvC,CAAC,KAAK,KAAK,KAAKA,CAAG,EAAG,CACxB,IAAMC,EAAO,KAAK,KAClB,KAAK,KAAOA,EAAK,KAAO,IAAIR,EAAa,EAAI,KAAK,KAAK,OAAO,MAAM,EACpE,KAAK,KAAK,KAAKO,CAAG,CACpB,CACF,CAEA,OAAK,CACH,IAAIA,EAAM,KAAK,KAAK,MAAK,EAEzB,GAAIA,IAAQ,QAAc,KAAK,KAAK,MAAQ,KAAO,CACjD,IAAME,EAAO,KAAK,KAAK,KACvB,KAAK,KAAK,KAAO,KACjB,KAAK,KAAOA,EACZF,EAAM,KAAK,KAAK,MAAK,CACvB,CAEA,OAAIA,GAAK,OAAS,OAChB,KAAK,MAAQ,KAAK,cAAcA,EAAI,KAAK,GAGpCA,CACT,CAEA,SAAO,CACL,OAAO,KAAK,KAAK,QAAO,CAC1B,GF7DI,IAAOG,EAAP,cAA0B,KAAK,CACnC,KACA,KAEA,YAAaC,EAAkBC,EAAa,CAC1C,MAAMD,GAAW,2BAA2B,EAC5C,KAAK,KAAO,UACZ,KAAK,KAAOC,GAAQ,WACtB,GAoFI,SAAUC,EAAaC,EAAmB,CAAA,EAAE,CAmBhD,OAAOC,EAlBUC,GAAkC,CACjD,IAAMC,EAA4BD,EAAO,MAAK,EAE9C,GAAIC,GAAQ,KACV,MAAO,CAAE,KAAM,EAAI,EAGrB,GAAIA,EAAK,OAAS,KAChB,MAAMA,EAAK,MAGb,MAAO,CACL,KAAMA,EAAK,OAAS,GAEpB,MAAOA,EAAK,MAEhB,EAE6CH,CAAO,CACtD,CAIM,SAAUI,EAAcJ,EAAmB,CAAA,EAAE,CAgCjD,OAAOC,EA/BUC,GAAoC,CACnD,IAAIC,EACEE,EAAc,CAAA,EAEpB,KAAO,CAACH,EAAO,QAAO,IACpBC,EAAOD,EAAO,MAAK,EAEfC,GAAQ,OAHY,CAOxB,GAAIA,EAAK,OAAS,KAChB,MAAMA,EAAK,MAGTA,EAAK,OAAS,IAEhBE,EAAO,KAAKF,EAAK,KAAK,CAE1B,CAEA,OAAIA,GAAQ,KACH,CAAE,KAAM,EAAI,EAGd,CACL,KAAMA,EAAK,OAAS,GACpB,MAAOE,EAEX,EAEgDL,CAAO,CACzD,CAEA,SAASC,EAA4CK,EAAuCN,EAAiB,CAC3GA,EAAUA,GAAW,CAAA,EACrB,IAAIO,EAAQP,EAAQ,MAChBE,EAAS,IAAIM,EACbT,EACAU,EACAC,EACAC,EAAQC,EAAQ,EAEdC,EAAW,SAA2C,CAC1D,GAAI,CACF,OAAKX,EAAO,QAAO,EAIfQ,EACK,CAAE,KAAM,EAAI,EAGd,MAAM,IAAI,QAA+B,CAACI,EAASC,IAAU,CAClEN,EAAUN,GAAwB,CAChCM,EAAS,KACTP,EAAO,KAAKC,CAAI,EAEhB,GAAI,CACFW,EAAQR,EAAQJ,CAAM,CAAC,CACzB,OAASc,EAAK,CACZD,EAAOC,CAAG,CACZ,CAEA,OAAOjB,CACT,CACF,CAAC,EApBQO,EAAQJ,CAAM,CAqBzB,SACMA,EAAO,QAAO,GAGhB,eAAe,IAAK,CAClBS,EAAM,QAAO,EACbA,EAAQC,EAAQ,CAClB,CAAC,CAEL,CACF,EAEMK,EAAcd,GACdM,GAAU,KACLA,EAAON,CAAI,GAGpBD,EAAO,KAAKC,CAAI,EACTJ,GAGHmB,EAAeF,IACnBd,EAAS,IAAIM,EAETC,GAAU,KACLA,EAAO,CAAE,MAAOO,CAAG,CAAE,GAG9Bd,EAAO,KAAK,CAAE,MAAOc,CAAG,CAAE,EACnBjB,IAGHoB,EAAQC,GAA+B,CAC3C,GAAIV,EACF,OAAOX,EAIT,GAAIC,GAAS,aAAe,IAAQoB,GAAO,YAAc,KACvD,MAAM,IAAI,MAAM,gEAAgE,EAGlF,OAAOH,EAAW,CAAE,KAAM,GAAO,MAAAG,CAAK,CAAE,CAC1C,EACMC,EAAOL,GACPN,EAAgBX,GACpBW,EAAQ,GAEAM,GAAO,KAAQE,EAAYF,CAAG,EAAIC,EAAW,CAAE,KAAM,EAAI,CAAE,GAE/DK,EAAU,KACdpB,EAAS,IAAIM,EACba,EAAG,EAEI,CAAE,KAAM,EAAI,GAEfE,EAAUP,IACdK,EAAIL,CAAG,EAEA,CAAE,KAAM,EAAI,GA+CrB,GA5CAjB,EAAW,CACT,CAAC,OAAO,aAAa,GAAC,CAAM,OAAO,IAAK,EACxC,KAAMc,EACN,OAAQS,EACR,MAAOC,EACP,KAAAJ,EACA,IAAAE,EACA,IAAI,gBAAc,CAChB,OAAOnB,EAAO,IAChB,EACA,QAAS,MAAOF,GAA0B,CACxC,IAAMwB,EAASxB,GAAS,OAGxB,GAFAwB,GAAQ,eAAc,EAElBtB,EAAO,QAAO,EAChB,OAGF,IAAIuB,EACAC,EAEAF,GAAU,OACZC,EAAS,IAAI,QAAQ,CAACX,EAASC,IAAU,CACvCW,EAAW,IAAK,CACdX,EAAO,IAAInB,CAAY,CACzB,EAEA4B,EAAO,iBAAiB,QAASE,CAAQ,CAC3C,CAAC,GAGH,GAAI,CACF,MAAM,QAAQ,KAAK,CACjBf,EAAM,QACNc,EACD,CACH,SACMC,GAAY,MAAQF,GAAU,MAChCA,GAAQ,oBAAoB,QAASE,CAAQ,CAEjD,CACF,GAGEnB,GAAS,KACX,OAAOR,EAGT,IAAME,EAAYF,EAElB,OAAAA,EAAW,CACT,CAAC,OAAO,aAAa,GAAC,CAAM,OAAO,IAAK,EACxC,MAAI,CACF,OAAOE,EAAU,KAAI,CACvB,EACA,MAAOe,EAAU,CACf,OAAAf,EAAU,MAAMe,CAAG,EAEfT,GAAS,OACXA,EAAMS,CAAG,EACTT,EAAQ,QAGH,CAAE,KAAM,EAAI,CACrB,EACA,QAAM,CACJ,OAAAN,EAAU,OAAM,EAEZM,GAAS,OACXA,EAAK,EACLA,EAAQ,QAGH,CAAE,KAAM,EAAI,CACrB,EACA,KAAAY,EACA,IAAKH,EAAU,CACb,OAAAf,EAAU,IAAIe,CAAG,EAEbT,GAAS,OACXA,EAAMS,CAAG,EACTT,EAAQ,QAGHR,CACT,EACA,IAAI,gBAAc,CAChB,OAAOE,EAAU,cACnB,EACA,QAAU0B,GACD1B,EAAU,QAAQ0B,CAAI,GAI1B5B,CACT",
+  "names": ["index_exports", "__export", "AbortError", "pushable", "pushableV", "pDefer", "deferred", "resolve", "reject", "FixedFIFO", "hwm", "data", "last", "FIFO", "options", "obj", "val", "prev", "next", "AbortError", "message", "code", "pushable", "options", "_pushable", "buffer", "next", "pushableV", "values", "getNext", "onEnd", "FIFO", "onNext", "ended", "drain", "pDefer", "waitNext", "resolve", "reject", "err", "bufferNext", "bufferError", "push", "value", "end", "_return", "_throw", "signal", "cancel", "listener", "opts"]
+}

dist/index.min.js

 (function (root, factory) {(typeof module === 'object' && module.exports) ? module.exports = factory() : root.ItPushable = factory()}(typeof self !== 'undefined' ? self : this, function () {
-"use strict";var ItPushable=(()=>{var y=Object.defineProperty;var S=Object.getOwnPropertyDescriptor;var _=Object.getOwnPropertyNames;var M=Object.prototype.hasOwnProperty;var P=(i,e)=>{for(var r in e)y(i,r,{get:e[r],enumerable:!0})},A=(i,e,r,t)=>{if(e&&typeof e=="object"||typeof e=="function")for(let u of _(e))!M.call(i,u)&&u!==r&&y(i,u,{get:()=>e[u],enumerable:!(t=S(e,u))||t.enumerable});return i};var I=i=>A(y({},"__esModule",{value:!0}),i);var T={};P(T,{AbortError:()=>b,pushable:()=>R,pushableV:()=>j});function c(){let i={};return i.promise=new Promise((e,r)=>{i.resolve=e,i.reject=r}),i}var p=class{buffer;mask;top;btm;next;constructor(e){if(!(e>0)||e-1&e)throw new Error("Max size for a FixedFIFO should be a power of two");this.buffer=new Array(e),this.mask=e-1,this.top=0,this.btm=0,this.next=null}push(e){return this.buffer[this.top]!==void 0?!1:(this.buffer[this.top]=e,this.top=this.top+1&this.mask,!0)}shift(){let e=this.buffer[this.btm];if(e!==void 0)return this.buffer[this.btm]=void 0,this.btm=this.btm+1&this.mask,e}isEmpty(){return this.buffer[this.btm]===void 0}},a=class{size;hwm;head;tail;constructor(e={}){this.hwm=e.splitLimit??16,this.head=new p(this.hwm),this.tail=this.head,this.size=0}calculateSize(e){return e?.byteLength!=null?e.byteLength:1}push(e){if(e?.value!=null&&(this.size+=this.calculateSize(e.value)),!this.head.push(e)){let r=this.head;this.head=r.next=new p(2*this.head.buffer.length),this.head.push(e)}}shift(){let e=this.tail.shift();if(e===void 0&&this.tail.next!=null){let r=this.tail.next;this.tail.next=null,this.tail=r,e=this.tail.shift()}return e?.value!=null&&(this.size-=this.calculateSize(e.value)),e}isEmpty(){return this.head.isEmpty()}};var b=class extends Error{type;code;constructor(e,r){super(e??"The operation was aborted"),this.type="aborted",this.code=r??"ABORT_ERR"}};function R(i={}){return g(r=>{let t=r.shift();if(t==null)return{done:!0};if(t.error!=null)throw t.error;return{done:t.done===!0,value:t.value}},i)}function j(i={}){return g(r=>{let t,u=[];for(;!r.isEmpty()&&(t=r.shift(),t!=null);){if(t.error!=null)throw t.error;t.done===!1&&u.push(t.value)}return t==null?{done:!0}:{done:t.done===!0,value:u}},i)}function g(i,e){e=e??{};let r=e.onEnd,t=new a,u,l,f,m=c(),v=async()=>{try{return t.isEmpty()?f?{done:!0}:await new Promise((n,s)=>{l=d=>{l=null,t.push(d);try{n(i(t))}catch(h){s(h)}return u}}):i(t)}finally{t.isEmpty()&&queueMicrotask(()=>{m.resolve(),m=c()})}},x=n=>l!=null?l(n):(t.push(n),u),z=n=>(t=new a,l!=null?l({error:n}):(t.push({error:n}),u)),E=n=>{if(f)return u;if(e?.objectMode!==!0&&n?.byteLength==null)throw new Error("objectMode was not true but tried to push non-Uint8Array value");return x({done:!1,value:n})},w=n=>f?u:(f=!0,n!=null?z(n):x({done:!0})),L=()=>(t=new a,w(),{done:!0}),k=n=>(w(n),{done:!0});if(u={[Symbol.asyncIterator](){return this},next:v,return:L,throw:k,push:E,end:w,get readableLength(){return t.size},onEmpty:async n=>{let s=n?.signal;if(s?.throwIfAborted(),t.isEmpty())return;let d,h;s!=null&&(d=new Promise((q,N)=>{h=()=>{N(new b)},s.addEventListener("abort",h)}));try{await Promise.race([m.promise,d])}finally{h!=null&&s!=null&&s?.removeEventListener("abort",h)}}},r==null)return u;let o=u;return u={[Symbol.asyncIterator](){return this},next(){return o.next()},throw(n){return o.throw(n),r!=null&&(r(n),r=void 0),{done:!0}},return(){return o.return(),r!=null&&(r(),r=void 0),{done:!0}},push:E,end(n){return o.end(n),r!=null&&(r(n),r=void 0),u},get readableLength(){return o.readableLength},onEmpty:n=>o.onEmpty(n)},u}return I(T);})();
+"use strict";var ItPushable=(()=>{var y=Object.defineProperty;var S=Object.getOwnPropertyDescriptor;var _=Object.getOwnPropertyNames;var M=Object.prototype.hasOwnProperty;var P=(i,e)=>{for(var r in e)y(i,r,{get:e[r],enumerable:!0})},A=(i,e,r,t)=>{if(e&&typeof e=="object"||typeof e=="function")for(let u of _(e))!M.call(i,u)&&u!==r&&y(i,u,{get:()=>e[u],enumerable:!(t=S(e,u))||t.enumerable});return i};var I=i=>A(y({},"__esModule",{value:!0}),i);var T={};P(T,{AbortError:()=>b,pushable:()=>R,pushableV:()=>j});function c(){let i={};return i.promise=new Promise((e,r)=>{i.resolve=e,i.reject=r}),i}var p=class{buffer;mask;top;btm;next;constructor(e){if(!(e>0)||(e-1&e)!==0)throw new Error("Max size for a FixedFIFO should be a power of two");this.buffer=new Array(e),this.mask=e-1,this.top=0,this.btm=0,this.next=null}push(e){return this.buffer[this.top]!==void 0?!1:(this.buffer[this.top]=e,this.top=this.top+1&this.mask,!0)}shift(){let e=this.buffer[this.btm];if(e!==void 0)return this.buffer[this.btm]=void 0,this.btm=this.btm+1&this.mask,e}isEmpty(){return this.buffer[this.btm]===void 0}},a=class{size;hwm;head;tail;constructor(e={}){this.hwm=e.splitLimit??16,this.head=new p(this.hwm),this.tail=this.head,this.size=0}calculateSize(e){return e?.byteLength!=null?e.byteLength:1}push(e){if(e?.value!=null&&(this.size+=this.calculateSize(e.value)),!this.head.push(e)){let r=this.head;this.head=r.next=new p(2*this.head.buffer.length),this.head.push(e)}}shift(){let e=this.tail.shift();if(e===void 0&&this.tail.next!=null){let r=this.tail.next;this.tail.next=null,this.tail=r,e=this.tail.shift()}return e?.value!=null&&(this.size-=this.calculateSize(e.value)),e}isEmpty(){return this.head.isEmpty()}};var b=class extends Error{type;code;constructor(e,r){super(e??"The operation was aborted"),this.type="aborted",this.code=r??"ABORT_ERR"}};function R(i={}){return g(r=>{let t=r.shift();if(t==null)return{done:!0};if(t.error!=null)throw t.error;return{done:t.done===!0,value:t.value}},i)}function j(i={}){return g(r=>{let t,u=[];for(;!r.isEmpty()&&(t=r.shift(),t!=null);){if(t.error!=null)throw t.error;t.done===!1&&u.push(t.value)}return t==null?{done:!0}:{done:t.done===!0,value:u}},i)}function g(i,e){e=e??{};let r=e.onEnd,t=new a,u,l,f,m=c(),v=async()=>{try{return t.isEmpty()?f?{done:!0}:await new Promise((n,s)=>{l=d=>{l=null,t.push(d);try{n(i(t))}catch(h){s(h)}return u}}):i(t)}finally{t.isEmpty()&&queueMicrotask(()=>{m.resolve(),m=c()})}},x=n=>l!=null?l(n):(t.push(n),u),z=n=>(t=new a,l!=null?l({error:n}):(t.push({error:n}),u)),E=n=>{if(f)return u;if(e?.objectMode!==!0&&n?.byteLength==null)throw new Error("objectMode was not true but tried to push non-Uint8Array value");return x({done:!1,value:n})},w=n=>f?u:(f=!0,n!=null?z(n):x({done:!0})),L=()=>(t=new a,w(),{done:!0}),k=n=>(w(n),{done:!0});if(u={[Symbol.asyncIterator](){return this},next:v,return:L,throw:k,push:E,end:w,get readableLength(){return t.size},onEmpty:async n=>{let s=n?.signal;if(s?.throwIfAborted(),t.isEmpty())return;let d,h;s!=null&&(d=new Promise((q,N)=>{h=()=>{N(new b)},s.addEventListener("abort",h)}));try{await Promise.race([m.promise,d])}finally{h!=null&&s!=null&&s?.removeEventListener("abort",h)}}},r==null)return u;let o=u;return u={[Symbol.asyncIterator](){return this},next(){return o.next()},throw(n){return o.throw(n),r!=null&&(r(n),r=void 0),{done:!0}},return(){return o.return(),r!=null&&(r(),r=void 0),{done:!0}},push:E,end(n){return o.end(n),r!=null&&(r(n),r=void 0),u},get readableLength(){return o.readableLength},onEmpty:n=>o.onEmpty(n)},u}return I(T);})();
 return ItPushable}));
+//# sourceMappingURL=index.min.js.map

dist/src/fifo.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"fifo.js","sourceRoot":"","sources":["../../src/fifo.ts"],"names":[],"mappings":"AAAA,sDAAsD;AAQtD,MAAM,SAAS;IACN,MAAM,CAA4B;IACxB,IAAI,CAAQ;IACrB,GAAG,CAAQ;IACX,GAAG,CAAQ;IACZ,IAAI,CAAqB;IAEhC,YAAa,GAAW;QACtB,IAAI,CAAC,CAAC,GAAG,GAAG,CAAC,CAAC,IAAI,CAAC,CAAC,GAAG,GAAG,CAAC,CAAC,GAAG,GAAG,CAAC,KAAK,CAAC,EAAE;YACzC,MAAM,IAAI,KAAK,CAAC,mDAAmD,CAAC,CAAA;SACrE;QAED,IAAI,CAAC,MAAM,GAAG,IAAI,KAAK,CAAC,GAAG,CAAC,CAAA;QAC5B,IAAI,CAAC,IAAI,GAAG,GAAG,GAAG,CAAC,CAAA;QACnB,IAAI,CAAC,GAAG,GAAG,CAAC,CAAA;QACZ,IAAI,CAAC,GAAG,GAAG,CAAC,CAAA;QACZ,IAAI,CAAC,IAAI,GAAG,IAAI,CAAA;IAClB,CAAC;IAED,IAAI,CAAE,IAAa;QACjB,IAAI,IAAI,CAAC,MAAM,CAAC,IAAI,CAAC,GAAG,CAAC,KAAK,SAAS,EAAE;YACvC,OAAO,KAAK,CAAA;SACb;QAED,IAAI,CAAC,MAAM,CAAC,IAAI,CAAC,GAAG,CAAC,GAAG,IAAI,CAAA;QAC5B,IAAI,CAAC,GAAG,GAAG,CAAC,IAAI,CAAC,GAAG,GAAG,CAAC,CAAC,GAAG,IAAI,CAAC,IAAI,CAAA;QAErC,OAAO,IAAI,CAAA;IACb,CAAC;IAED,KAAK;QACH,MAAM,IAAI,GAAG,IAAI,CAAC,MAAM,CAAC,IAAI,CAAC,GAAG,CAAC,CAAA;QAElC,IAAI,IAAI,KAAK,SAAS,EAAE;YACtB,OAAO,SAAS,CAAA;SACjB;QAED,IAAI,CAAC,MAAM,CAAC,IAAI,CAAC,GAAG,CAAC,GAAG,SAAS,CAAA;QACjC,IAAI,CAAC,GAAG,GAAG,CAAC,IAAI,CAAC,GAAG,GAAG,CAAC,CAAC,GAAG,IAAI,CAAC,IAAI,CAAA;QACrC,OAAO,IAAI,CAAA;IACb,CAAC;IAED,OAAO;QACL,OAAO,IAAI,CAAC,MAAM,CAAC,IAAI,CAAC,GAAG,CAAC,KAAK,SAAS,CAAA;IAC5C,CAAC;CACF;AASD,MAAM,OAAO,IAAI;IACR,IAAI,CAAQ;IACF,GAAG,CAAQ;IACpB,IAAI,CAAc;IAClB,IAAI,CAAc;IAE1B,YAAa,UAAuB,EAAE;QACpC,IAAI,CAAC,GAAG,GAAG,OAAO,CAAC,UAAU,IAAI,EAAE,CAAA;QACnC,IAAI,CAAC,IAAI,GAAG,IAAI,SAAS,CAAI,IAAI,CAAC,GAAG,CAAC,CAAA;QACtC,IAAI,CAAC,IAAI,GAAG,IAAI,CAAC,IAAI,CAAA;QACrB,IAAI,CAAC,IAAI,GAAG,CAAC,CAAA;IACf,CAAC;IAED,aAAa,CAAE,GAAQ;QACrB,IAAI,GAAG,EAAE,UAAU,IAAI,IAAI,EAAE;YAC3B,OAAO,GAAG,CAAC,UAAU,CAAA;SACtB;QAED,OAAO,CAAC,CAAA;IACV,CAAC;IAED,IAAI,CAAE,GAAY;QAChB,IAAI,GAAG,EAAE,KAAK,IAAI,IAAI,EAAE;YACtB,IAAI,CAAC,IAAI,IAAI,IAAI,CAAC,aAAa,CAAC,GAAG,CAAC,KAAK,CAAC,CAAA;SAC3C;QAED,IAAI,CAAC,IAAI,CAAC,IAAI,CAAC,IAAI,CAAC,GAAG,CAAC,EAAE;YACxB,MAAM,IAAI,GAAG,IAAI,CAAC,IAAI,CAAA;YACtB,IAAI,CAAC,IAAI,GAAG,IAAI,CAAC,IAAI,GAAG,IAAI,SAAS,CAAI,CAAC,GAAG,IAAI,CAAC,IAAI,CAAC,MAAM,CAAC,MAAM,CAAC,CAAA;YACrE,IAAI,CAAC,IAAI,CAAC,IAAI,CAAC,GAAG,CAAC,CAAA;SACpB;IACH,CAAC;IAED,KAAK;QACH,IAAI,GAAG,GAAG,IAAI,CAAC,IAAI,CAAC,KAAK,EAAE,CAAA;QAE3B,IAAI,GAAG,KAAK,SAAS,IAAI,CAAC,IAAI,CAAC,IAAI,CAAC,IAAI,IAAI,IAAI,CAAC,EAAE;YACjD,MAAM,IAAI,GAAG,IAAI,CAAC,IAAI,CAAC,IAAI,CAAA;YAC3B,IAAI,CAAC,IAAI,CAAC,IAAI,GAAG,IAAI,CAAA;YACrB,IAAI,CAAC,IAAI,GAAG,IAAI,CAAA;YAChB,GAAG,GAAG,IAAI,CAAC,IAAI,CAAC,KAAK,EAAE,CAAA;SACxB;QAED,IAAI,GAAG,EAAE,KAAK,IAAI,IAAI,EAAE;YACtB,IAAI,CAAC,IAAI,IAAI,IAAI,CAAC,aAAa,CAAC,GAAG,CAAC,KAAK,CAAC,CAAA;SAC3C;QAED,OAAO,GAAG,CAAA;IACZ,CAAC;IAED,OAAO;QACL,OAAO,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,CAAA;IAC5B,CAAC;CACF"}
+{"version":3,"file":"fifo.js","sourceRoot":"","sources":["../../src/fifo.ts"],"names":[],"mappings":"AAAA,sDAAsD;AAQtD,MAAM,SAAS;IACN,MAAM,CAA4B;IACxB,IAAI,CAAQ;IACrB,GAAG,CAAQ;IACX,GAAG,CAAQ;IACZ,IAAI,CAAqB;IAEhC,YAAa,GAAW;QACtB,IAAI,CAAC,CAAC,GAAG,GAAG,CAAC,CAAC,IAAI,CAAC,CAAC,GAAG,GAAG,CAAC,CAAC,GAAG,GAAG,CAAC,KAAK,CAAC,EAAE,CAAC;YAC1C,MAAM,IAAI,KAAK,CAAC,mDAAmD,CAAC,CAAA;QACtE,CAAC;QAED,IAAI,CAAC,MAAM,GAAG,IAAI,KAAK,CAAC,GAAG,CAAC,CAAA;QAC5B,IAAI,CAAC,IAAI,GAAG,GAAG,GAAG,CAAC,CAAA;QACnB,IAAI,CAAC,GAAG,GAAG,CAAC,CAAA;QACZ,IAAI,CAAC,GAAG,GAAG,CAAC,CAAA;QACZ,IAAI,CAAC,IAAI,GAAG,IAAI,CAAA;IAClB,CAAC;IAED,IAAI,CAAE,IAAa;QACjB,IAAI,IAAI,CAAC,MAAM,CAAC,IAAI,CAAC,GAAG,CAAC,KAAK,SAAS,EAAE,CAAC;YACxC,OAAO,KAAK,CAAA;QACd,CAAC;QAED,IAAI,CAAC,MAAM,CAAC,IAAI,CAAC,GAAG,CAAC,GAAG,IAAI,CAAA;QAC5B,IAAI,CAAC,GAAG,GAAG,CAAC,IAAI,CAAC,GAAG,GAAG,CAAC,CAAC,GAAG,IAAI,CAAC,IAAI,CAAA;QAErC,OAAO,IAAI,CAAA;IACb,CAAC;IAED,KAAK;QACH,MAAM,IAAI,GAAG,IAAI,CAAC,MAAM,CAAC,IAAI,CAAC,GAAG,CAAC,CAAA;QAElC,IAAI,IAAI,KAAK,SAAS,EAAE,CAAC;YACvB,OAAO,SAAS,CAAA;QAClB,CAAC;QAED,IAAI,CAAC,MAAM,CAAC,IAAI,CAAC,GAAG,CAAC,GAAG,SAAS,CAAA;QACjC,IAAI,CAAC,GAAG,GAAG,CAAC,IAAI,CAAC,GAAG,GAAG,CAAC,CAAC,GAAG,IAAI,CAAC,IAAI,CAAA;QACrC,OAAO,IAAI,CAAA;IACb,CAAC;IAED,OAAO;QACL,OAAO,IAAI,CAAC,MAAM,CAAC,IAAI,CAAC,GAAG,CAAC,KAAK,SAAS,CAAA;IAC5C,CAAC;CACF;AASD,MAAM,OAAO,IAAI;IACR,IAAI,CAAQ;IACF,GAAG,CAAQ;IACpB,IAAI,CAAc;IAClB,IAAI,CAAc;IAE1B,YAAa,UAAuB,EAAE;QACpC,IAAI,CAAC,GAAG,GAAG,OAAO,CAAC,UAAU,IAAI,EAAE,CAAA;QACnC,IAAI,CAAC,IAAI,GAAG,IAAI,SAAS,CAAI,IAAI,CAAC,GAAG,CAAC,CAAA;QACtC,IAAI,CAAC,IAAI,GAAG,IAAI,CAAC,IAAI,CAAA;QACrB,IAAI,CAAC,IAAI,GAAG,CAAC,CAAA;IACf,CAAC;IAED,aAAa,CAAE,GAAQ;QACrB,IAAI,GAAG,EAAE,UAAU,IAAI,IAAI,EAAE,CAAC;YAC5B,OAAO,GAAG,CAAC,UAAU,CAAA;QACvB,CAAC;QAED,OAAO,CAAC,CAAA;IACV,CAAC;IAED,IAAI,CAAE,GAAY;QAChB,IAAI,GAAG,EAAE,KAAK,IAAI,IAAI,EAAE,CAAC;YACvB,IAAI,CAAC,IAAI,IAAI,IAAI,CAAC,aAAa,CAAC,GAAG,CAAC,KAAK,CAAC,CAAA;QAC5C,CAAC;QAED,IAAI,CAAC,IAAI,CAAC,IAAI,CAAC,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC;YACzB,MAAM,IAAI,GAAG,IAAI,CAAC,IAAI,CAAA;YACtB,IAAI,CAAC,IAAI,GAAG,IAAI,CAAC,IAAI,GAAG,IAAI,SAAS,CAAI,CAAC,GAAG,IAAI,CAAC,IAAI,CAAC,MAAM,CAAC,MAAM,CAAC,CAAA;YACrE,IAAI,CAAC,IAAI,CAAC,IAAI,CAAC,GAAG,CAAC,CAAA;QACrB,CAAC;IACH,CAAC;IAED,KAAK;QACH,IAAI,GAAG,GAAG,IAAI,CAAC,IAAI,CAAC,KAAK,EAAE,CAAA;QAE3B,IAAI,GAAG,KAAK,SAAS,IAAI,CAAC,IAAI,CAAC,IAAI,CAAC,IAAI,IAAI,IAAI,CAAC,EAAE,CAAC;YAClD,MAAM,IAAI,GAAG,IAAI,CAAC,IAAI,CAAC,IAAI,CAAA;YAC3B,IAAI,CAAC,IAAI,CAAC,IAAI,GAAG,IAAI,CAAA;YACrB,IAAI,CAAC,IAAI,GAAG,IAAI,CAAA;YAChB,GAAG,GAAG,IAAI,CAAC,IAAI,CAAC,KAAK,EAAE,CAAA;QACzB,CAAC;QAED,IAAI,GAAG,EAAE,KAAK,IAAI,IAAI,EAAE,CAAC;YACvB,IAAI,CAAC,IAAI,IAAI,IAAI,CAAC,aAAa,CAAC,GAAG,CAAC,KAAK,CAAC,CAAA;QAC5C,CAAC;QAED,OAAO,GAAG,CAAA;IACZ,CAAC;IAED,OAAO;QACL,OAAO,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,CAAA;IAC5B,CAAC;CACF"}

dist/src/index.d.ts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"index.d.ts","sourceRoot":"","sources":["../../src/index.ts"],"names":[],"mappings":"AAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;GA+CG;AAKH,qBAAa,UAAW,SAAQ,KAAK;IACnC,IAAI,EAAE,MAAM,CAAA;IACZ,IAAI,EAAE,MAAM,CAAA;gBAEC,OAAO,CAAC,EAAE,MAAM,EAAE,IAAI,CAAC,EAAE,MAAM;CAK7C;AAED,MAAM,WAAW,YAAY;IAC3B,MAAM,CAAC,EAAE,WAAW,CAAA;CACrB;AAED,UAAU,YAAY,CAAC,CAAC;IACtB;;;;OAIG;IACH,GAAG,CAAC,GAAG,CAAC,EAAE,KAAK,GAAG,IAAI,CAAA;IAEtB;;;OAGG;IACH,IAAI,CAAC,KAAK,EAAE,CAAC,GAAG,IAAI,CAAA;IAEpB;;;;;;OAMG;IACH,OAAO,CAAC,OAAO,CAAC,EAAE,YAAY,GAAG,OAAO,CAAC,IAAI,CAAC,CAAA;IAE9C;;;;;OAKG;IACH,cAAc,EAAE,MAAM,CAAA;CACvB;AAED;;GAEG;AACH,MAAM,WAAW,QAAQ,CAAC,CAAC,EAAE,CAAC,GAAG,IAAI,EAAE,CAAC,GAAG,OAAO,CAAE,SAAQ,cAAc,CAAC,CAAC,EAAE,CAAC,EAAE,CAAC,CAAC,EAAE,YAAY,CAAC,CAAC,CAAC;CAAG;AAEvG;;GAEG;AACH,MAAM,WAAW,SAAS,CAAC,CAAC,EAAE,CAAC,GAAG,IAAI,EAAE,CAAC,GAAG,OAAO,CAAE,SAAQ,cAAc,CAAC,CAAC,EAAE,EAAE,CAAC,EAAE,CAAC,CAAC,EAAE,YAAY,CAAC,CAAC,CAAC;CAAG;AAE1G,MAAM,WAAW,OAAO;IACtB;;OAEG;IACH,UAAU,CAAC,EAAE,OAAO,CAAA;IAEpB;;;;OAIG;IACH,KAAK,CAAC,CAAC,GAAG,CAAC,EAAE,KAAK,GAAG,IAAI,CAAA;CAC1B;AAED,MAAM,WAAW,UAAU;IAAG,IAAI,EAAE,IAAI,CAAA;CAAE;AAC1C,MAAM,WAAW,WAAW,CAAC,CAAC;IAAI,IAAI,EAAE,KAAK,CAAC;IAAC,KAAK,EAAE,CAAC,CAAA;CAAE;AACzD,MAAM,MAAM,UAAU,CAAC,CAAC,IAAI,WAAW,CAAC,CAAC,CAAC,GAAG,UAAU,CAAA;AAIvD,MAAM,WAAW,qBAAsB,SAAQ,OAAO;IACpD,UAAU,EAAE,IAAI,CAAA;CACjB;AAED,MAAM,WAAW,mBAAoB,SAAQ,OAAO;IAClD,UAAU,CAAC,EAAE,KAAK,CAAA;CACnB;AAED;;;;GAIG;AACH,wBAAgB,QAAQ,CAAC,CAAC,SAAS;IAAE,UAAU,EAAE,MAAM,CAAA;CAAE,GAAG,UAAU,EAAG,OAAO,CAAC,EAAE,mBAAmB,GAAG,QAAQ,CAAC,CAAC,CAAC,CAAA;AACpH,wBAAgB,QAAQ,CAAC,CAAC,EAAG,OAAO,EAAE,qBAAqB,GAAG,QAAQ,CAAC,CAAC,CAAC,CAAA;AAuBzE,wBAAgB,SAAS,CAAC,CAAC,SAAS;IAAE,UAAU,EAAE,MAAM,CAAA;CAAE,GAAG,UAAU,EAAG,OAAO,CAAC,EAAE,mBAAmB,GAAG,SAAS,CAAC,CAAC,CAAC,CAAA;AACtH,wBAAgB,SAAS,CAAC,CAAC,EAAG,OAAO,EAAE,qBAAqB,GAAG,SAAS,CAAC,CAAC,CAAC,CAAA"}
+{"version":3,"file":"index.d.ts","sourceRoot":"","sources":["../../src/index.ts"],"names":[],"mappings":"AAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;GA+CG;AAMH,qBAAa,UAAW,SAAQ,KAAK;IACnC,IAAI,EAAE,MAAM,CAAA;IACZ,IAAI,EAAE,MAAM,CAAA;gBAEC,OAAO,CAAC,EAAE,MAAM,EAAE,IAAI,CAAC,EAAE,MAAM;CAK7C;AAED,MAAM,WAAW,YAAY;IAC3B,MAAM,CAAC,EAAE,WAAW,CAAA;CACrB;AAED,UAAU,YAAY,CAAC,CAAC;IACtB;;;;OAIG;IACH,GAAG,CAAC,GAAG,CAAC,EAAE,KAAK,GAAG,IAAI,CAAA;IAEtB;;;OAGG;IACH,IAAI,CAAC,KAAK,EAAE,CAAC,GAAG,IAAI,CAAA;IAEpB;;;;;;OAMG;IACH,OAAO,CAAC,OAAO,CAAC,EAAE,YAAY,GAAG,OAAO,CAAC,IAAI,CAAC,CAAA;IAE9C;;;;;OAKG;IACH,cAAc,EAAE,MAAM,CAAA;CACvB;AAED;;GAEG;AACH,MAAM,WAAW,QAAQ,CAAC,CAAC,EAAE,CAAC,GAAG,IAAI,EAAE,CAAC,GAAG,OAAO,CAAE,SAAQ,cAAc,CAAC,CAAC,EAAE,CAAC,EAAE,CAAC,CAAC,EAAE,YAAY,CAAC,CAAC,CAAC;CAAG;AAEvG;;GAEG;AACH,MAAM,WAAW,SAAS,CAAC,CAAC,EAAE,CAAC,GAAG,IAAI,EAAE,CAAC,GAAG,OAAO,CAAE,SAAQ,cAAc,CAAC,CAAC,EAAE,EAAE,CAAC,EAAE,CAAC,CAAC,EAAE,YAAY,CAAC,CAAC,CAAC;CAAG;AAE1G,MAAM,WAAW,OAAO;IACtB;;OAEG;IACH,UAAU,CAAC,EAAE,OAAO,CAAA;IAEpB;;;;OAIG;IACH,KAAK,CAAC,CAAC,GAAG,CAAC,EAAE,KAAK,GAAG,IAAI,CAAA;CAC1B;AAED,MAAM,WAAW,UAAU;IAAG,IAAI,EAAE,IAAI,CAAA;CAAE;AAC1C,MAAM,WAAW,WAAW,CAAC,CAAC;IAAI,IAAI,EAAE,KAAK,CAAC;IAAC,KAAK,EAAE,CAAC,CAAA;CAAE;AACzD,MAAM,MAAM,UAAU,CAAC,CAAC,IAAI,WAAW,CAAC,CAAC,CAAC,GAAG,UAAU,CAAA;AAIvD,MAAM,WAAW,qBAAsB,SAAQ,OAAO;IACpD,UAAU,EAAE,IAAI,CAAA;CACjB;AAED,MAAM,WAAW,mBAAoB,SAAQ,OAAO;IAClD,UAAU,CAAC,EAAE,KAAK,CAAA;CACnB;AAED;;;;GAIG;AACH,wBAAgB,QAAQ,CAAC,CAAC,SAAS;IAAE,UAAU,EAAE,MAAM,CAAA;CAAE,GAAG,UAAU,EAAG,OAAO,CAAC,EAAE,mBAAmB,GAAG,QAAQ,CAAC,CAAC,CAAC,CAAA;AACpH,wBAAgB,QAAQ,CAAC,CAAC,EAAG,OAAO,EAAE,qBAAqB,GAAG,QAAQ,CAAC,CAAC,CAAC,CAAA;AAuBzE,wBAAgB,SAAS,CAAC,CAAC,SAAS;IAAE,UAAU,EAAE,MAAM,CAAA;CAAE,GAAG,UAAU,EAAG,OAAO,CAAC,EAAE,mBAAmB,GAAG,SAAS,CAAC,CAAC,CAAC,CAAA;AACtH,wBAAgB,SAAS,CAAC,CAAC,EAAG,OAAO,EAAE,qBAAqB,GAAG,SAAS,CAAC,CAAC,CAAC,CAAA"}

dist/src/index.js

@@ -50,3 +50,3 @@ /**
 import deferred from 'p-defer';
-import { FIFO } from './fifo.js';
+import { FIFO } from "./fifo.js";
 export class AbortError extends Error {
@@ -172,4 +172,5 @@ type;
     const end = (err) => {
-        if (ended)
+        if (ended) {
             return pushable;
+        }
         ended = true;
@@ -176,0 +177,0 @@ return (err != null) ? bufferError(err) : bufferNext({ done: true });

dist/src/index.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"index.js","sourceRoot":"","sources":["../../src/index.ts"],"names":[],"mappings":"AAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;GA+CG;AAEH,OAAO,QAAQ,MAAM,SAAS,CAAA;AAC9B,OAAO,EAAE,IAAI,EAAa,MAAM,WAAW,CAAA;AAE3C,MAAM,OAAO,UAAW,SAAQ,KAAK;IACnC,IAAI,CAAQ;IACZ,IAAI,CAAQ;IAEZ,YAAa,OAAgB,EAAE,IAAa;QAC1C,KAAK,CAAC,OAAO,IAAI,2BAA2B,CAAC,CAAA;QAC7C,IAAI,CAAC,IAAI,GAAG,SAAS,CAAA;QACrB,IAAI,CAAC,IAAI,GAAG,IAAI,IAAI,WAAW,CAAA;IACjC,CAAC;CACF;AAmFD,MAAM,UAAU,QAAQ,CAAK,UAAmB,EAAE;IAChD,MAAM,OAAO,GAAG,CAAC,MAAe,EAAiB,EAAE;QACjD,MAAM,IAAI,GAAwB,MAAM,CAAC,KAAK,EAAE,CAAA;QAEhD,IAAI,IAAI,IAAI,IAAI,EAAE;YAChB,OAAO,EAAE,IAAI,EAAE,IAAI,EAAE,CAAA;SACtB;QAED,IAAI,IAAI,CAAC,KAAK,IAAI,IAAI,EAAE;YACtB,MAAM,IAAI,CAAC,KAAK,CAAA;SACjB;QAED,OAAO;YACL,IAAI,EAAE,IAAI,CAAC,IAAI,KAAK,IAAI;YACxB,2DAA2D;YAC3D,KAAK,EAAE,IAAI,CAAC,KAAK;SAClB,CAAA;IACH,CAAC,CAAA;IAED,OAAO,SAAS,CAAoB,OAAO,EAAE,OAAO,CAAC,CAAA;AACvD,CAAC;AAID,MAAM,UAAU,SAAS,CAAK,UAAmB,EAAE;IACjD,MAAM,OAAO,GAAG,CAAC,MAAe,EAAmB,EAAE;QACnD,IAAI,IAAyB,CAAA;QAC7B,MAAM,MAAM,GAAQ,EAAE,CAAA;QAEtB,OAAO,CAAC,MAAM,CAAC,OAAO,EAAE,EAAE;YACxB,IAAI,GAAG,MAAM,CAAC,KAAK,EAAE,CAAA;YAErB,IAAI,IAAI,IAAI,IAAI,EAAE;gBAChB,MAAK;aACN;YAED,IAAI,IAAI,CAAC,KAAK,IAAI,IAAI,EAAE;gBACtB,MAAM,IAAI,CAAC,KAAK,CAAA;aACjB;YAED,IAAI,IAAI,CAAC,IAAI,KAAK,KAAK,EAAE;gBACvB,2DAA2D;gBAC3D,MAAM,CAAC,IAAI,CAAC,IAAI,CAAC,KAAK,CAAC,CAAA;aACxB;SACF;QAED,IAAI,IAAI,IAAI,IAAI,EAAE;YAChB,OAAO,EAAE,IAAI,EAAE,IAAI,EAAE,CAAA;SACtB;QAED,OAAO;YACL,IAAI,EAAE,IAAI,CAAC,IAAI,KAAK,IAAI;YACxB,KAAK,EAAE,MAAM;SACd,CAAA;IACH,CAAC,CAAA;IAED,OAAO,SAAS,CAAuB,OAAO,EAAE,OAAO,CAAC,CAAA;AAC1D,CAAC;AAED,SAAS,SAAS,CAAmC,OAAqC,EAAE,OAAiB;IAC3G,OAAO,GAAG,OAAO,IAAI,EAAE,CAAA;IACvB,IAAI,KAAK,GAAG,OAAO,CAAC,KAAK,CAAA;IACzB,IAAI,MAAM,GAAG,IAAI,IAAI,EAAY,CAAA;IACjC,IAAI,QAAa,CAAA;IACjB,IAAI,MAAqD,CAAA;IACzD,IAAI,KAAc,CAAA;IAClB,IAAI,KAAK,GAAG,QAAQ,EAAE,CAAA;IAEtB,MAAM,QAAQ,GAAG,KAAK,IAAoC,EAAE;QAC1D,IAAI;YACF,IAAI,CAAC,MAAM,CAAC,OAAO,EAAE,EAAE;gBACrB,OAAO,OAAO,CAAC,MAAM,CAAC,CAAA;aACvB;YAED,IAAI,KAAK,EAAE;gBACT,OAAO,EAAE,IAAI,EAAE,IAAI,EAAE,CAAA;aACtB;YAED,OAAO,MAAM,IAAI,OAAO,CAAwB,CAAC,OAAO,EAAE,MAAM,EAAE,EAAE;gBAClE,MAAM,GAAG,CAAC,IAAoB,EAAE,EAAE;oBAChC,MAAM,GAAG,IAAI,CAAA;oBACb,MAAM,CAAC,IAAI,CAAC,IAAI,CAAC,CAAA;oBAEjB,IAAI;wBACF,OAAO,CAAC,OAAO,CAAC,MAAM,CAAC,CAAC,CAAA;qBACzB;oBAAC,OAAO,GAAG,EAAE;wBACZ,MAAM,CAAC,GAAG,CAAC,CAAA;qBACZ;oBAED,OAAO,QAAQ,CAAA;gBACjB,CAAC,CAAA;YACH,CAAC,CAAC,CAAA;SACH;gBAAS;YACR,IAAI,MAAM,CAAC,OAAO,EAAE,EAAE;gBACpB,sEAAsE;gBACtE,4BAA4B;gBAC5B,cAAc,CAAC,GAAG,EAAE;oBAClB,KAAK,CAAC,OAAO,EAAE,CAAA;oBACf,KAAK,GAAG,QAAQ,EAAE,CAAA;gBACpB,CAAC,CAAC,CAAA;aACH;SACF;IACH,CAAC,CAAA;IAED,MAAM,UAAU,GAAG,CAAC,IAAoB,EAAc,EAAE;QACtD,IAAI,MAAM,IAAI,IAAI,EAAE;YAClB,OAAO,MAAM,CAAC,IAAI,CAAC,CAAA;SACpB;QAED,MAAM,CAAC,IAAI,CAAC,IAAI,CAAC,CAAA;QACjB,OAAO,QAAQ,CAAA;IACjB,CAAC,CAAA;IAED,MAAM,WAAW,GAAG,CAAC,GAAU,EAAc,EAAE;QAC7C,MAAM,GAAG,IAAI,IAAI,EAAE,CAAA;QAEnB,IAAI,MAAM,IAAI,IAAI,EAAE;YAClB,OAAO,MAAM,CAAC,EAAE,KAAK,EAAE,GAAG,EAAE,CAAC,CAAA;SAC9B;QAED,MAAM,CAAC,IAAI,CAAC,EAAE,KAAK,EAAE,GAAG,EAAE,CAAC,CAAA;QAC3B,OAAO,QAAQ,CAAA;IACjB,CAAC,CAAA;IAED,MAAM,IAAI,GAAG,CAAC,KAAe,EAAc,EAAE;QAC3C,IAAI,KAAK,EAAE;YACT,OAAO,QAAQ,CAAA;SAChB;QAED,4DAA4D;QAC5D,IAAI,OAAO,EAAE,UAAU,KAAK,IAAI,IAAI,KAAK,EAAE,UAAU,IAAI,IAAI,EAAE;YAC7D,MAAM,IAAI,KAAK,CAAC,gEAAgE,CAAC,CAAA;SAClF;QAED,OAAO,UAAU,CAAC,EAAE,IAAI,EAAE,KAAK,EAAE,KAAK,EAAE,CAAC,CAAA;IAC3C,CAAC,CAAA;IACD,MAAM,GAAG,GAAG,CAAC,GAAW,EAAc,EAAE;QACtC,IAAI,KAAK;YAAE,OAAO,QAAQ,CAAA;QAC1B,KAAK,GAAG,IAAI,CAAA;QAEZ,OAAO,CAAC,GAAG,IAAI,IAAI,CAAC,CAAC,CAAC,CAAC,WAAW,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC,UAAU,CAAC,EAAE,IAAI,EAAE,IAAI,EAAE,CAAC,CAAA;IACtE,CAAC,CAAA;IACD,MAAM,OAAO,GAAG,GAAe,EAAE;QAC/B,MAAM,GAAG,IAAI,IAAI,EAAE,CAAA;QACnB,GAAG,EAAE,CAAA;QAEL,OAAO,EAAE,IAAI,EAAE,IAAI,EAAE,CAAA;IACvB,CAAC,CAAA;IACD,MAAM,MAAM,GAAG,CAAC,GAAU,EAAc,EAAE;QACxC,GAAG,CAAC,GAAG,CAAC,CAAA;QAER,OAAO,EAAE,IAAI,EAAE,IAAI,EAAE,CAAA;IACvB,CAAC,CAAA;IAED,QAAQ,GAAG;QACT,CAAC,MAAM,CAAC,aAAa,CAAC,KAAM,OAAO,IAAI,CAAA,CAAC,CAAC;QACzC,IAAI,EAAE,QAAQ;QACd,MAAM,EAAE,OAAO;QACf,KAAK,EAAE,MAAM;QACb,IAAI;QACJ,GAAG;QACH,IAAI,cAAc;YAChB,OAAO,MAAM,CAAC,IAAI,CAAA;QACpB,CAAC;QACD,OAAO,EAAE,KAAK,EAAE,OAAsB,EAAE,EAAE;YACxC,MAAM,MAAM,GAAG,OAAO,EAAE,MAAM,CAAA;YAC9B,MAAM,EAAE,cAAc,EAAE,CAAA;YAExB,IAAI,MAAM,CAAC,OAAO,EAAE,EAAE;gBACpB,OAAM;aACP;YAED,IAAI,MAAiC,CAAA;YACrC,IAAI,QAAkC,CAAA;YAEtC,IAAI,MAAM,IAAI,IAAI,EAAE;gBAClB,MAAM,GAAG,IAAI,OAAO,CAAC,CAAC,OAAO,EAAE,MAAM,EAAE,EAAE;oBACvC,QAAQ,GAAG,GAAG,EAAE;wBACd,MAAM,CAAC,IAAI,UAAU,EAAE,CAAC,CAAA;oBAC1B,CAAC,CAAA;oBAED,MAAM,CAAC,gBAAgB,CAAC,OAAO,EAAE,QAAQ,CAAC,CAAA;gBAC5C,CAAC,CAAC,CAAA;aACH;YAED,IAAI;gBACF,MAAM,OAAO,CAAC,IAAI,CAAC;oBACjB,KAAK,CAAC,OAAO;oBACb,MAAM;iBACP,CAAC,CAAA;aACH;oBAAS;gBACR,IAAI,QAAQ,IAAI,IAAI,IAAI,MAAM,IAAI,IAAI,EAAE;oBACtC,MAAM,EAAE,mBAAmB,CAAC,OAAO,EAAE,QAAQ,CAAC,CAAA;iBAC/C;aACF;QACH,CAAC;KACF,CAAA;IAED,IAAI,KAAK,IAAI,IAAI,EAAE;QACjB,OAAO,QAAQ,CAAA;KAChB;IAED,MAAM,SAAS,GAAG,QAAQ,CAAA;IAE1B,QAAQ,GAAG;QACT,CAAC,MAAM,CAAC,aAAa,CAAC,KAAM,OAAO,IAAI,CAAA,CAAC,CAAC;QACzC,IAAI;YACF,OAAO,SAAS,CAAC,IAAI,EAAE,CAAA;QACzB,CAAC;QACD,KAAK,CAAE,GAAU;YACf,SAAS,CAAC,KAAK,CAAC,GAAG,CAAC,CAAA;YAEpB,IAAI,KAAK,IAAI,IAAI,EAAE;gBACjB,KAAK,CAAC,GAAG,CAAC,CAAA;gBACV,KAAK,GAAG,SAAS,CAAA;aAClB;YAED,OAAO,EAAE,IAAI,EAAE,IAAI,EAAE,CAAA;QACvB,CAAC;QACD,MAAM;YACJ,SAAS,CAAC,MAAM,EAAE,CAAA;YAElB,IAAI,KAAK,IAAI,IAAI,EAAE;gBACjB,KAAK,EAAE,CAAA;gBACP,KAAK,GAAG,SAAS,CAAA;aAClB;YAED,OAAO,EAAE,IAAI,EAAE,IAAI,EAAE,CAAA;QACvB,CAAC;QACD,IAAI;QACJ,GAAG,CAAE,GAAU;YACb,SAAS,CAAC,GAAG,CAAC,GAAG,CAAC,CAAA;YAElB,IAAI,KAAK,IAAI,IAAI,EAAE;gBACjB,KAAK,CAAC,GAAG,CAAC,CAAA;gBACV,KAAK,GAAG,SAAS,CAAA;aAClB;YAED,OAAO,QAAQ,CAAA;QACjB,CAAC;QACD,IAAI,cAAc;YAChB,OAAO,SAAS,CAAC,cAAc,CAAA;QACjC,CAAC;QACD,OAAO,EAAE,CAAC,IAAmB,EAAE,EAAE;YAC/B,OAAO,SAAS,CAAC,OAAO,CAAC,IAAI,CAAC,CAAA;QAChC,CAAC;KACF,CAAA;IAED,OAAO,QAAQ,CAAA;AACjB,CAAC"}
+{"version":3,"file":"index.js","sourceRoot":"","sources":["../../src/index.ts"],"names":[],"mappings":"AAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;GA+CG;AAEH,OAAO,QAAQ,MAAM,SAAS,CAAA;AAC9B,OAAO,EAAE,IAAI,EAAE,MAAM,WAAW,CAAA;AAGhC,MAAM,OAAO,UAAW,SAAQ,KAAK;IACnC,IAAI,CAAQ;IACZ,IAAI,CAAQ;IAEZ,YAAa,OAAgB,EAAE,IAAa;QAC1C,KAAK,CAAC,OAAO,IAAI,2BAA2B,CAAC,CAAA;QAC7C,IAAI,CAAC,IAAI,GAAG,SAAS,CAAA;QACrB,IAAI,CAAC,IAAI,GAAG,IAAI,IAAI,WAAW,CAAA;IACjC,CAAC;CACF;AAmFD,MAAM,UAAU,QAAQ,CAAK,UAAmB,EAAE;IAChD,MAAM,OAAO,GAAG,CAAC,MAAe,EAAiB,EAAE;QACjD,MAAM,IAAI,GAAwB,MAAM,CAAC,KAAK,EAAE,CAAA;QAEhD,IAAI,IAAI,IAAI,IAAI,EAAE,CAAC;YACjB,OAAO,EAAE,IAAI,EAAE,IAAI,EAAE,CAAA;QACvB,CAAC;QAED,IAAI,IAAI,CAAC,KAAK,IAAI,IAAI,EAAE,CAAC;YACvB,MAAM,IAAI,CAAC,KAAK,CAAA;QAClB,CAAC;QAED,OAAO;YACL,IAAI,EAAE,IAAI,CAAC,IAAI,KAAK,IAAI;YACxB,2DAA2D;YAC3D,KAAK,EAAE,IAAI,CAAC,KAAK;SAClB,CAAA;IACH,CAAC,CAAA;IAED,OAAO,SAAS,CAAoB,OAAO,EAAE,OAAO,CAAC,CAAA;AACvD,CAAC;AAID,MAAM,UAAU,SAAS,CAAK,UAAmB,EAAE;IACjD,MAAM,OAAO,GAAG,CAAC,MAAe,EAAmB,EAAE;QACnD,IAAI,IAAyB,CAAA;QAC7B,MAAM,MAAM,GAAQ,EAAE,CAAA;QAEtB,OAAO,CAAC,MAAM,CAAC,OAAO,EAAE,EAAE,CAAC;YACzB,IAAI,GAAG,MAAM,CAAC,KAAK,EAAE,CAAA;YAErB,IAAI,IAAI,IAAI,IAAI,EAAE,CAAC;gBACjB,MAAK;YACP,CAAC;YAED,IAAI,IAAI,CAAC,KAAK,IAAI,IAAI,EAAE,CAAC;gBACvB,MAAM,IAAI,CAAC,KAAK,CAAA;YAClB,CAAC;YAED,IAAI,IAAI,CAAC,IAAI,KAAK,KAAK,EAAE,CAAC;gBACxB,2DAA2D;gBAC3D,MAAM,CAAC,IAAI,CAAC,IAAI,CAAC,KAAK,CAAC,CAAA;YACzB,CAAC;QACH,CAAC;QAED,IAAI,IAAI,IAAI,IAAI,EAAE,CAAC;YACjB,OAAO,EAAE,IAAI,EAAE,IAAI,EAAE,CAAA;QACvB,CAAC;QAED,OAAO;YACL,IAAI,EAAE,IAAI,CAAC,IAAI,KAAK,IAAI;YACxB,KAAK,EAAE,MAAM;SACd,CAAA;IACH,CAAC,CAAA;IAED,OAAO,SAAS,CAAuB,OAAO,EAAE,OAAO,CAAC,CAAA;AAC1D,CAAC;AAED,SAAS,SAAS,CAAmC,OAAqC,EAAE,OAAiB;IAC3G,OAAO,GAAG,OAAO,IAAI,EAAE,CAAA;IACvB,IAAI,KAAK,GAAG,OAAO,CAAC,KAAK,CAAA;IACzB,IAAI,MAAM,GAAG,IAAI,IAAI,EAAY,CAAA;IACjC,IAAI,QAAa,CAAA;IACjB,IAAI,MAAqD,CAAA;IACzD,IAAI,KAAc,CAAA;IAClB,IAAI,KAAK,GAAG,QAAQ,EAAE,CAAA;IAEtB,MAAM,QAAQ,GAAG,KAAK,IAAoC,EAAE;QAC1D,IAAI,CAAC;YACH,IAAI,CAAC,MAAM,CAAC,OAAO,EAAE,EAAE,CAAC;gBACtB,OAAO,OAAO,CAAC,MAAM,CAAC,CAAA;YACxB,CAAC;YAED,IAAI,KAAK,EAAE,CAAC;gBACV,OAAO,EAAE,IAAI,EAAE,IAAI,EAAE,CAAA;YACvB,CAAC;YAED,OAAO,MAAM,IAAI,OAAO,CAAwB,CAAC,OAAO,EAAE,MAAM,EAAE,EAAE;gBAClE,MAAM,GAAG,CAAC,IAAoB,EAAE,EAAE;oBAChC,MAAM,GAAG,IAAI,CAAA;oBACb,MAAM,CAAC,IAAI,CAAC,IAAI,CAAC,CAAA;oBAEjB,IAAI,CAAC;wBACH,OAAO,CAAC,OAAO,CAAC,MAAM,CAAC,CAAC,CAAA;oBAC1B,CAAC;oBAAC,OAAO,GAAG,EAAE,CAAC;wBACb,MAAM,CAAC,GAAG,CAAC,CAAA;oBACb,CAAC;oBAED,OAAO,QAAQ,CAAA;gBACjB,CAAC,CAAA;YACH,CAAC,CAAC,CAAA;QACJ,CAAC;gBAAS,CAAC;YACT,IAAI,MAAM,CAAC,OAAO,EAAE,EAAE,CAAC;gBACrB,sEAAsE;gBACtE,4BAA4B;gBAC5B,cAAc,CAAC,GAAG,EAAE;oBAClB,KAAK,CAAC,OAAO,EAAE,CAAA;oBACf,KAAK,GAAG,QAAQ,EAAE,CAAA;gBACpB,CAAC,CAAC,CAAA;YACJ,CAAC;QACH,CAAC;IACH,CAAC,CAAA;IAED,MAAM,UAAU,GAAG,CAAC,IAAoB,EAAc,EAAE;QACtD,IAAI,MAAM,IAAI,IAAI,EAAE,CAAC;YACnB,OAAO,MAAM,CAAC,IAAI,CAAC,CAAA;QACrB,CAAC;QAED,MAAM,CAAC,IAAI,CAAC,IAAI,CAAC,CAAA;QACjB,OAAO,QAAQ,CAAA;IACjB,CAAC,CAAA;IAED,MAAM,WAAW,GAAG,CAAC,GAAU,EAAc,EAAE;QAC7C,MAAM,GAAG,IAAI,IAAI,EAAE,CAAA;QAEnB,IAAI,MAAM,IAAI,IAAI,EAAE,CAAC;YACnB,OAAO,MAAM,CAAC,EAAE,KAAK,EAAE,GAAG,EAAE,CAAC,CAAA;QAC/B,CAAC;QAED,MAAM,CAAC,IAAI,CAAC,EAAE,KAAK,EAAE,GAAG,EAAE,CAAC,CAAA;QAC3B,OAAO,QAAQ,CAAA;IACjB,CAAC,CAAA;IAED,MAAM,IAAI,GAAG,CAAC,KAAe,EAAc,EAAE;QAC3C,IAAI,KAAK,EAAE,CAAC;YACV,OAAO,QAAQ,CAAA;QACjB,CAAC;QAED,4DAA4D;QAC5D,IAAI,OAAO,EAAE,UAAU,KAAK,IAAI,IAAI,KAAK,EAAE,UAAU,IAAI,IAAI,EAAE,CAAC;YAC9D,MAAM,IAAI,KAAK,CAAC,gEAAgE,CAAC,CAAA;QACnF,CAAC;QAED,OAAO,UAAU,CAAC,EAAE,IAAI,EAAE,KAAK,EAAE,KAAK,EAAE,CAAC,CAAA;IAC3C,CAAC,CAAA;IACD,MAAM,GAAG,GAAG,CAAC,GAAW,EAAc,EAAE;QACtC,IAAI,KAAK,EAAE,CAAC;YAAC,OAAO,QAAQ,CAAA;QAAC,CAAC;QAC9B,KAAK,GAAG,IAAI,CAAA;QAEZ,OAAO,CAAC,GAAG,IAAI,IAAI,CAAC,CAAC,CAAC,CAAC,WAAW,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC,UAAU,CAAC,EAAE,IAAI,EAAE,IAAI,EAAE,CAAC,CAAA;IACtE,CAAC,CAAA;IACD,MAAM,OAAO,GAAG,GAAe,EAAE;QAC/B,MAAM,GAAG,IAAI,IAAI,EAAE,CAAA;QACnB,GAAG,EAAE,CAAA;QAEL,OAAO,EAAE,IAAI,EAAE,IAAI,EAAE,CAAA;IACvB,CAAC,CAAA;IACD,MAAM,MAAM,GAAG,CAAC,GAAU,EAAc,EAAE;QACxC,GAAG,CAAC,GAAG,CAAC,CAAA;QAER,OAAO,EAAE,IAAI,EAAE,IAAI,EAAE,CAAA;IACvB,CAAC,CAAA;IAED,QAAQ,GAAG;QACT,CAAC,MAAM,CAAC,aAAa,CAAC,KAAM,OAAO,IAAI,CAAA,CAAC,CAAC;QACzC,IAAI,EAAE,QAAQ;QACd,MAAM,EAAE,OAAO;QACf,KAAK,EAAE,MAAM;QACb,IAAI;QACJ,GAAG;QACH,IAAI,cAAc;YAChB,OAAO,MAAM,CAAC,IAAI,CAAA;QACpB,CAAC;QACD,OAAO,EAAE,KAAK,EAAE,OAAsB,EAAE,EAAE;YACxC,MAAM,MAAM,GAAG,OAAO,EAAE,MAAM,CAAA;YAC9B,MAAM,EAAE,cAAc,EAAE,CAAA;YAExB,IAAI,MAAM,CAAC,OAAO,EAAE,EAAE,CAAC;gBACrB,OAAM;YACR,CAAC;YAED,IAAI,MAAiC,CAAA;YACrC,IAAI,QAAkC,CAAA;YAEtC,IAAI,MAAM,IAAI,IAAI,EAAE,CAAC;gBACnB,MAAM,GAAG,IAAI,OAAO,CAAC,CAAC,OAAO,EAAE,MAAM,EAAE,EAAE;oBACvC,QAAQ,GAAG,GAAG,EAAE;wBACd,MAAM,CAAC,IAAI,UAAU,EAAE,CAAC,CAAA;oBAC1B,CAAC,CAAA;oBAED,MAAM,CAAC,gBAAgB,CAAC,OAAO,EAAE,QAAQ,CAAC,CAAA;gBAC5C,CAAC,CAAC,CAAA;YACJ,CAAC;YAED,IAAI,CAAC;gBACH,MAAM,OAAO,CAAC,IAAI,CAAC;oBACjB,KAAK,CAAC,OAAO;oBACb,MAAM;iBACP,CAAC,CAAA;YACJ,CAAC;oBAAS,CAAC;gBACT,IAAI,QAAQ,IAAI,IAAI,IAAI,MAAM,IAAI,IAAI,EAAE,CAAC;oBACvC,MAAM,EAAE,mBAAmB,CAAC,OAAO,EAAE,QAAQ,CAAC,CAAA;gBAChD,CAAC;YACH,CAAC;QACH,CAAC;KACF,CAAA;IAED,IAAI,KAAK,IAAI,IAAI,EAAE,CAAC;QAClB,OAAO,QAAQ,CAAA;IACjB,CAAC;IAED,MAAM,SAAS,GAAG,QAAQ,CAAA;IAE1B,QAAQ,GAAG;QACT,CAAC,MAAM,CAAC,aAAa,CAAC,KAAM,OAAO,IAAI,CAAA,CAAC,CAAC;QACzC,IAAI;YACF,OAAO,SAAS,CAAC,IAAI,EAAE,CAAA;QACzB,CAAC;QACD,KAAK,CAAE,GAAU;YACf,SAAS,CAAC,KAAK,CAAC,GAAG,CAAC,CAAA;YAEpB,IAAI,KAAK,IAAI,IAAI,EAAE,CAAC;gBAClB,KAAK,CAAC,GAAG,CAAC,CAAA;gBACV,KAAK,GAAG,SAAS,CAAA;YACnB,CAAC;YAED,OAAO,EAAE,IAAI,EAAE,IAAI,EAAE,CAAA;QACvB,CAAC;QACD,MAAM;YACJ,SAAS,CAAC,MAAM,EAAE,CAAA;YAElB,IAAI,KAAK,IAAI,IAAI,EAAE,CAAC;gBAClB,KAAK,EAAE,CAAA;gBACP,KAAK,GAAG,SAAS,CAAA;YACnB,CAAC;YAED,OAAO,EAAE,IAAI,EAAE,IAAI,EAAE,CAAA;QACvB,CAAC;QACD,IAAI;QACJ,GAAG,CAAE,GAAU;YACb,SAAS,CAAC,GAAG,CAAC,GAAG,CAAC,CAAA;YAElB,IAAI,KAAK,IAAI,IAAI,EAAE,CAAC;gBAClB,KAAK,CAAC,GAAG,CAAC,CAAA;gBACV,KAAK,GAAG,SAAS,CAAA;YACnB,CAAC;YAED,OAAO,QAAQ,CAAA;QACjB,CAAC;QACD,IAAI,cAAc;YAChB,OAAO,SAAS,CAAC,cAAc,CAAA;QACjC,CAAC;QACD,OAAO,EAAE,CAAC,IAAmB,EAAE,EAAE;YAC/B,OAAO,SAAS,CAAC,OAAO,CAAC,IAAI,CAAC,CAAA;QAChC,CAAC;KACF,CAAA;IAED,OAAO,QAAQ,CAAA;AACjB,CAAC"}

dist/typedoc-urls.json

@@ -22,6 +22,6 @@ {
   ".:NextResult": "https://alanshaw.github.io/it-pushable/types/NextResult.html",
-  "pushable": "https://alanshaw.github.io/it-pushable/functions/pushable-1.html",
-  ".:pushable": "https://alanshaw.github.io/it-pushable/functions/pushable-1.html",
-  "pushableV": "https://alanshaw.github.io/it-pushable/functions/pushableV-1.html",
-  ".:pushableV": "https://alanshaw.github.io/it-pushable/functions/pushableV-1.html"
+  "pushable": "https://alanshaw.github.io/it-pushable/functions/pushable.html",
+  ".:pushable": "https://alanshaw.github.io/it-pushable/functions/pushable.html",
+  "pushableV": "https://alanshaw.github.io/it-pushable/functions/pushableV.html",
+  ".:pushableV": "https://alanshaw.github.io/it-pushable/functions/pushableV.html"
 }

package.json

 {
   "name": "it-pushable",
-  "version": "3.2.3",
+  "version": "3.2.4",
   "description": "An iterable that you can push values into",
@@ -15,2 +15,6 @@ "author": "Alan Shaw",
   },
+  "publishConfig": {
+    "access": "public",
+    "provenance": true
+  },
   "keywords": [
@@ -33,12 +37,6 @@ "iterable",
       "types": "./dist/src/index.d.ts",
-      "import": "./dist/src/index.js"
+      "import": "./dist/src/index.js",
+      "module-sync": "./dist/src/index.js"
     }
   },
-  "eslintConfig": {
-    "extends": "ipfs",
-    "parserOptions": {
-      "project": true,
-      "sourceType": "module"
-    }
-  },
   "release": {
@@ -126,3 +124,11 @@ "branches": [
       "@semantic-release/github",
-      "@semantic-release/git"
+      [
+        "@semantic-release/git",
+        {
+          "assets": [
+            "CHANGELOG.md",
+            "package.json"
+          ]
+        }
+      ]
     ]
@@ -150,3 +156,3 @@ },
     "@types/fast-fifo": "^1.0.0",
-    "aegir": "^41.0.5",
+    "aegir": "^48.0.1",
     "it-all": "^3.0.1",
@@ -153,0 +159,0 @@ "it-pipe": "^3.0.1",

README.md

@@ -10,2 +10,17 @@ # it-pushable <!-- omit in toc -->
 
+<!--
+
+!IMPORTANT!
+
+Everything in this README between "# About" and "# Install" is automatically
+generated and will be overwritten the next time the doc generator is run.
+
+To make changes to this section, please update the @packageDocumentation section
+of src/index.js or src/index.ts
+
+To experiment with formatting, please run "npm run docs" from the root of this
+repo and examine the changes made.
+
+-->
+
 An iterable that you can push values into.
@@ -12,0 +27,0 @@

src/index.ts

@@ -51,3 +51,4 @@ /**
 import deferred from 'p-defer'
-import { FIFO, type Next } from './fifo.js'
+import { FIFO } from './fifo.ts'
+import type { Next } from './fifo.ts'
 
@@ -283,3 +284,3 @@ export class AbortError extends Error {
   const end = (err?: Error): ReturnType => {
-    if (ended) return pushable
+    if (ended) { return pushable }
     ended = true
@@ -286,0 +287,0 @@

LICENSE

-This project is dual licensed under MIT and Apache-2.0.
-
-MIT: https://www.opensource.org/licenses/mit
-Apache-2.0: https://www.apache.org/licenses/license-2.0

Fixed alerts

Mixed license

License

Package contains multiple licenses.

Improved metrics

Total package byte prevSize

67874

37.41%

Number of low license alerts

0

-100%

Lines of code

973

0.31%

Number of lines in readme file

156

10.64%

No dependency changes