|
@@ -219,15 +219,14 @@ export class StreamService {
|
|
|
let isPush: boolean;
|
|
|
// this.logger.log('statusPack', statusPack);
|
|
|
if (this.channel && this.channel.isOpen()) {
|
|
|
- this.channel.setBufferedAmountLowThreshold(262144);
|
|
|
isPush = this.channel.sendMessageBinary(
|
|
|
Buffer.from(framePack.buffer),
|
|
|
);
|
|
|
if (!isPush) {
|
|
|
- await this.sleep(10);
|
|
|
- isPush = this.channel.sendMessageBinary(
|
|
|
- Buffer.from(framePack.buffer),
|
|
|
- );
|
|
|
+ // await this.sleep(10);
|
|
|
+ // isPush = this.channel.sendMessageBinary(
|
|
|
+ // Buffer.from(framePack.buffer),
|
|
|
+ // );
|
|
|
console.error('流测试推不成功-二次试', i, isPush);
|
|
|
}
|
|
|
|