fix: reuse it-queueless-pushable

Use the queueless pushable from `it-queueless-pushable` as it was extracted from this module.
achingbrain · May 30, 2024 · 85f390f · 85f390f
1 parent e6179f0
commit 85f390f
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 138 deletions.
diff --git a/packages/it-byte-stream/package.json b/packages/it-byte-stream/package.json
@@ -136,6 +136,7 @@
     "release": "aegir release"
   },
   "dependencies": {
+    "it-queueless-pushable": "^1.0.0",
     "it-stream-types": "^2.0.1",
     "p-defer": "^4.0.1",
     "race-signal": "^1.0.2",

diff --git a/packages/it-byte-stream/src/index.ts b/packages/it-byte-stream/src/index.ts
@@ -22,7 +22,7 @@
  */
 
 import { Uint8ArrayList } from 'uint8arraylist'
-import { pushable } from './pushable.js'
+import { queuelessPushable } from 'it-queueless-pushable'
 import type { Duplex } from 'it-stream-types'
 
 export class CodeError extends Error {
@@ -76,7 +76,7 @@ export interface ByteStreamOpts {
 }
 
 export function byteStream <Stream extends Duplex<any, any, any>> (duplex: Stream, opts?: ByteStreamOpts): ByteStream<Stream> {
-  const write = pushable()
+  const write = queuelessPushable()
 
   duplex.sink(write).catch(async (err: Error) => {
     await write.end(err)

diff --git a/packages/it-byte-stream/src/pushable.ts b/packages/it-byte-stream/src/pushable.ts