jan/openreplay
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

combine in 1 line

Browse source
This commit is contained in:
Андрей Бабушкин 2025-03-21 15:18:10 +01:00
parent 1e2dde09b4
commit 5f9ed3a087
1 changed files with 5 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
tracker/tracker/src/main/app/index.ts
View file

@ -848,8 +848,7 @@ export default class App {
* */ * */
private _nCommit(): void { private _nCommit(): void {
if (this.socketMode) { if (this.socketMode) {
this.messages.unshift(TabData(this.session.getTabId())) this.messages.unshift(Timestamp(this.timestamp()), TabData(this.session.getTabId()))
this.messages.unshift(Timestamp(this.timestamp()))
this.commitCallbacks.forEach((cb) => cb(this.messages)) this.commitCallbacks.forEach((cb) => cb(this.messages))
this.messages.length = 0 this.messages.length = 0
return return
@ -874,8 +873,7 @@ export default class App {
try { try {
requestIdleCb(() => { requestIdleCb(() => {
this.messages.unshift(TabData(this.session.getTabId())) this.messages.unshift(Timestamp(this.timestamp()), TabData(this.session.getTabId()))
this.messages.unshift(Timestamp(this.timestamp()))
this.worker?.postMessage(this.messages) this.worker?.postMessage(this.messages)
this.commitCallbacks.forEach((cb) => cb(this.messages)) this.commitCallbacks.forEach((cb) => cb(this.messages))
this.messages.length = 0 this.messages.length = 0
@ -900,10 +898,9 @@ export default class App {
private _cStartCommit(): void { private _cStartCommit(): void {
this.coldStartCommitN += 1 this.coldStartCommitN += 1
if (this.coldStartCommitN === 2) { if (this.coldStartCommitN === 2) {
this.bufferedMessages1.push(Timestamp(this.timestamp())) const payload = [Timestamp(this.timestamp()), TabData(this.session.getTabId())]
this.bufferedMessages1.push(TabData(this.session.getTabId())) this.bufferedMessages1.push(...payload)
this.bufferedMessages2.push(Timestamp(this.timestamp())) this.bufferedMessages2.push(...payload)
this.bufferedMessages2.push(TabData(this.session.getTabId()))
this.coldStartCommitN = 0 this.coldStartCommitN = 0
} }
} }