|
@@ -108,7 +108,7 @@ export class StreamService {
|
|
|
*/
|
|
|
|
|
|
pushFrameToSteam(stream: StreamFrameType): Promise<StreamPushResponse> {
|
|
|
- return new Promise((resolve, reject) => {
|
|
|
+ return new Promise(async (resolve, reject) => {
|
|
|
try {
|
|
|
// let start, stop;
|
|
|
const start = performance.now();
|
|
@@ -209,6 +209,10 @@ export class StreamService {
|
|
|
const isPush = this.channel.sendMessageBinary(
|
|
|
Buffer.from(framePack.buffer),
|
|
|
);
|
|
|
+ if (!isPush) {
|
|
|
+ await this.sleep(5);
|
|
|
+ console.error('流测试推不成功-再试', isPush);
|
|
|
+ }
|
|
|
|
|
|
if (i === slices) {
|
|
|
this.onSteaming.next(false);
|