|
@@ -61,6 +61,7 @@ export class SceneService implements OnModuleInit, OnModuleDestroy {
|
|
private joystickSub: any;
|
|
private joystickSub: any;
|
|
private clickQueueSub: any;
|
|
private clickQueueSub: any;
|
|
private _rotateCurrentFame = -1;
|
|
private _rotateCurrentFame = -1;
|
|
|
|
+ private _rotateCount = -1;
|
|
|
|
|
|
private streamServiceSub: any;
|
|
private streamServiceSub: any;
|
|
// private roRequestQueue: RxQueue = new DelayQueue(20);
|
|
// private roRequestQueue: RxQueue = new DelayQueue(20);
|
|
@@ -240,6 +241,7 @@ export class SceneService implements OnModuleInit, OnModuleDestroy {
|
|
|
|
|
|
async rotate(request: RotateRequest) {
|
|
async rotate(request: RotateRequest) {
|
|
this.handleRotate(request);
|
|
this.handleRotate(request);
|
|
|
|
+ this._rotateCount += 1;
|
|
//this.logger.log('request', request)
|
|
//this.logger.log('request', request)
|
|
// this.roRequestQueue.next(request);
|
|
// this.roRequestQueue.next(request);
|
|
// if (!this.roRequestQueueSub) {
|
|
// if (!this.roRequestQueueSub) {
|
|
@@ -261,8 +263,8 @@ export class SceneService implements OnModuleInit, OnModuleDestroy {
|
|
let redisMeta: StreamReplyType;
|
|
let redisMeta: StreamReplyType;
|
|
this.onRotating.next(true);
|
|
this.onRotating.next(true);
|
|
const start = performance.now();
|
|
const start = performance.now();
|
|
- // 当move时处理
|
|
|
|
- if (this.onMoving.value) {
|
|
|
|
|
|
+ // 当move时处理 _rotateCount是移动端同时触发的问题
|
|
|
|
+ if (this.onMoving.value && this._rotateCount > 5) {
|
|
const lastStreamFrame = this.lastMoveStreamFrame.getValue();
|
|
const lastStreamFrame = this.lastMoveStreamFrame.getValue();
|
|
const metaData: StreamReplyType = JSON.parse(
|
|
const metaData: StreamReplyType = JSON.parse(
|
|
lastStreamFrame.metaData,
|
|
lastStreamFrame.metaData,
|