fix: incorrect File.stream() object this reference (#2672)

* fix: incorrect File.stream() object this reference * chore(style): remove trailing spaces
webtorrent · Oct 2, 2023 · 8577a47 · 8577a47
1 parent d07334f
commit 8577a47
Showing 1 changed file with 4 additions and 5 deletions.
diff --git a/lib/file.js b/lib/file.js
@@ -144,16 +144,15 @@ export default class File extends EventEmitter {
   stream (opts) {
     let iterator
     return new ReadableStream({
-      start () {
+      start: () => {
         iterator = this[Symbol.asyncIterator](opts)
       },
-      async pull ({ close, enqueue }) {
+      async pull (controller) {
         const { value, done } = await iterator.next()
-
         if (done) {
-          close()
+          controller.close()
         } else {
-          enqueue(value)
+          controller.enqueue(value)
         }
       },
       cancel () {