refactor: update TransformStream and ReadableStream to use arrow func…

…tions
Hazi7 · Jan 21, 2025 · ff8c48d · ff8c48d
1 parent 75225a9
commit ff8c48d
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 13 deletions.
diff --git a/src/core/flv-muxer.ts b/src/core/flv-muxer.ts
@@ -109,22 +109,20 @@ export class FlvMuxer {
   }
 
   private initTransform() {
-    let muxer = this;
-
     this.transform = new TransformStream({
-      async start(controller) {
-        const header = muxer.encoder.encodeFlvHeader(
-          !!muxer.options.video,
-          !!muxer.options.audio
+      start: async (controller) => {
+        const header = this.encoder.encodeFlvHeader(
+          !!this.options.video,
+          !!this.options.audio
         );
-        const metadata = muxer.encodeMetadata();
+        const metadata = this.encodeMetadata();
         controller.enqueue(header);
         controller.enqueue(metadata);
 
-        muxer.processor.start();
+        this.processor.start();
       },
-      transform(chunk, controller) {
-        const tag = muxer.muxChunk(chunk);
+      transform: (chunk, controller) => {
+        const tag = this.muxChunk(chunk);
         controller.enqueue(tag);
       },
     });

diff --git a/src/core/media-processor.ts b/src/core/media-processor.ts
@@ -82,10 +82,9 @@ export class MediaProcessor {
       this.readAndEncode(this.vStream.getReader(), this.vEncoder);
     }
 
-    const mediaProcessor = this;
     this.oStream = new ReadableStream({
-      start(controller) {
-        mediaProcessor.buffer.subscribe((data) => {
+      start: (controller) => {
+        this.buffer.subscribe((data) => {
           controller.enqueue(data);
         });
       },