changes

src/sub-router/showtime.ts

@@ -687,8 +687,6 @@ async function handle_data(arg0: {
         })
       });
 
-      console.log("E_, R_", E_, R_);
-
       if (E_ || !R_) {
         if (fMP4) {
           phase = "single";
@@ -696,10 +694,22 @@ async function handle_data(arg0: {
           use_s3_pipe = false;
         }
 
+        NS_Misc.console.log({
+          ENV: "all",
+          _browser: false,
+          _log: [`USING FFMPEG PIPE HANDLER`, "\n"]
+        });
+
         run({
           ii: 0,
           ...(fMP4 ? { keep_subs: true, rebuild: true } : {})
         });
+      } else {
+        NS_Misc.console.log({
+          ENV: "all",
+          _browser: false,
+          _log: [`USING STREAM HANDLER`, "\n"]
+        });
       }
     } else {
       run({

src/sub-router/stream.ts

@@ -1131,6 +1131,12 @@ async function handle_data(arg0: {
           _log: [`🏁 PHRASE [${phase}]: INIT`, "\n"]
         });
 
+        NS_Misc.console.log({
+          ENV: "all",
+          _browser: false,
+          _log: [`SENT TO FFMPEG PIPE HANDLER`, "\n"]
+        });
+
         // fetch(_);
 
         NS_promise.F_catch_promise({
@@ -1354,6 +1360,12 @@ function segmentStream(arg0: {
 }): ReadableStream<Uint8Array> {
   const { segments, init, headers, concurrency = 2, onSegment, onError } = arg0;
 
+  NS_Misc.console.log({
+    ENV: "all",
+    _browser: false,
+    _log: [`STREAM HANDLER: concurrency = ${concurrency}`, "\n"]
+  });
+
   const { readable, writable } = new TransformStream<Uint8Array, Uint8Array>();
   const ac = arg0.ac || new AbortController();
   const inflight: Promise<Response>[] = [];