fix: reuse it-queueless-pushable (#134)

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

Hide file tree

Showing 3 changed files with 3 additions and 140 deletions.
diff --git a/packages/it-byte-stream/package.json b/packages/it-byte-stream/package.json
@@ -136,9 +136,8 @@
     "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",
     "uint8arraylist": "^2.4.8"
   },
   "devDependencies": {

diff --git a/packages/it-byte-stream/src/index.ts b/packages/it-byte-stream/src/index.ts
@@ -21,8 +21,8 @@
  * ```
  */
 
+import { queuelessPushable } from 'it-queueless-pushable'
 import { Uint8ArrayList } from 'uint8arraylist'
-import { pushable } from './pushable.js'
 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