test

src/scene/stream/stream.service.ts

@@ -174,6 +174,13 @@ export class StreamService {
         );
 
         let steamByteLength = 0;
+        console.log(
+          'stream-size %s : frame: %s, IDR: %s',
+          ((coordBuff.byteLength + clipBuffer.byteLength) / 1024).toFixed(2) +
+          ' KB',
+          frame,
+          dir,
+        );
 
         for (let i = 0; i <= slices; i++) {
           this.onSteaming.next(true);
@@ -217,6 +224,7 @@ export class StreamService {
           steamByteLength += currentSlice.byteLength;
           // const isLastFrame = framePack.byteLength - this.chunk_size < 0;
           let isPush: boolean;
+
           // this.logger.log('statusPack', statusPack);
           if (this.channel && this.channel.isOpen()) {
             console.log(
@@ -253,9 +261,10 @@ export class StreamService {
                   clipPath: stream.clipPath,
                 });
               } else {
+                //TODO 临时强制为推送成功
                 return resolve({
                   frame: stream.frame,
-                  done: false,
+                  done: true,
                   clipPath: stream.clipPath,
                 });
               }
@@ -264,14 +273,7 @@ export class StreamService {
             return resolve({ frame: stream.frame, done: false });
           }
         }
-        // let steamByteLength = 0;
-        console.log(
-          'stream-size %s : frame: %s, IDR: %s',
-          ((coordBuff.byteLength + clipBuffer.byteLength) / 1024).toFixed(2) +
-          ' KB',
-          frame,
-          dir,
-        );
+
       } catch (error) {
         this.logger.error(error);
         return reject({ frame: stream.frame, done: false });