fix: migrate to streamx (#173)

* fix: migrate to streamx * chore: dump readable-stream dep
webtorrent · Sep 2, 2022 · 40a0f50 · 40a0f50
1 parent 02cd503
commit 40a0f50
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 9 deletions.
diff --git a/index.js b/index.js
@@ -11,7 +11,7 @@ const once = require('once')
 const parallel = require('run-parallel')
 const queueMicrotask = require('queue-microtask')
 const sha1 = require('simple-sha1')
-const stream = require('readable-stream')
+const { Transform, PassThrough } = require('streamx')
 
 const getFiles = require('./get-files') // browser exclude
 
@@ -424,7 +424,7 @@ function getBlobStream (file) {
  */
 function getBufferStream (buffer) {
   return () => {
-    const s = new stream.PassThrough()
+    const s = new PassThrough()
     s.end(buffer)
     return s
   }
@@ -440,11 +440,11 @@ function getBufferStream (buffer) {
  */
 function getStreamStream (readable, file) {
   return () => {
-    const counter = new stream.Transform()
-    counter._transform = function (buf, enc, done) {
-      file.length += buf.length
-      this.push(buf)
-      done()
+    const counter = new Transform()
+    counter._transform = function (data, cb) {
+      file.length += data.length
+      this.push(data)
+      cb()
     }
     readable.pipe(counter)
     return counter

diff --git a/package.json b/package.json
@@ -28,9 +28,9 @@
     "once": "^1.4.0",
     "piece-length": "^2.0.1",
     "queue-microtask": "^1.2.3",
-    "readable-stream": "^3.6.0",
     "run-parallel": "^1.2.0",
-    "simple-sha1": "^3.1.0"
+    "simple-sha1": "^3.1.0",
+    "streamx": "^2.12.4"
   },
   "devDependencies": {
     "@webtorrent/semantic-release-config": "1.0.7",