Arsharth/hydrogen-web
1
0
Fork 0
forked from mystiq/hydrogen-web
Code Issues Pull requests Projects Releases Packages Wiki Activity

Debounce range updates

Browse source
This commit is contained in:
Kegan Dougal 2021-12-10 12:06:14 +00:00
parent 639f4d673c
commit 9f0fec772e
1 changed files with 10 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
src/matrix/Sync3.ts
View file

@ -137,6 +137,7 @@ export class Sync3 {
// sync v3 specific: contains the sliding window ranges to request as well as the data structures // sync v3 specific: contains the sliding window ranges to request as well as the data structures
// to remember the indexes for each room. // to remember the indexes for each room.
private ranges: number[][]; private ranges: number[][];
private debounceTimeoutId: any;
private roomIndexToRoomId: IndexToRoomId; private roomIndexToRoomId: IndexToRoomId;
private roomIdToRoomIndex: RoomIdToIndex; private roomIdToRoomIndex: RoomIdToIndex;
private totalRooms: number; private totalRooms: number;
@ -169,6 +170,7 @@ export class Sync3 {
this.totalRooms = 0; this.totalRooms = 0;
this.currentRoomSubscriptions = []; this.currentRoomSubscriptions = [];
this.nextRoomSubscriptions = []; this.nextRoomSubscriptions = [];
this.debounceTimeoutId = 0;
} }
/** /**
@ -189,7 +191,7 @@ export class Sync3 {
* Load a new sliding window range for sync v3. * Load a new sliding window range for sync v3.
* *
* This range should be the part of the room list the user is currently looking at. No index * This range should be the part of the room list the user is currently looking at. No index
* padding will be performed (e.g viewing 10-20 so request 5-25). * padding will be performed (e.g viewing 10-20 so request 5-25). Debounces after a few milliseconds.
* @param start The start index (inclusive) * @param start The start index (inclusive)
* @param end The end index (inclusive) * @param end The end index (inclusive)
*/ */
@ -215,9 +217,13 @@ export class Sync3 {
} }
this.ranges[1][0] = start; this.ranges[1][0] = start;
this.ranges[1][1] = end; this.ranges[1][1] = end;
console.log("update ranges");
clearTimeout(this.debounceTimeoutId);
this.debounceTimeoutId = setTimeout(() => {
console.log("new sync v3 ranges: ", JSON.stringify(this.ranges)); console.log("new sync v3 ranges: ", JSON.stringify(this.ranges));
// interrupt the sync request to send up the new ranges // interrupt the sync request to send up the new ranges
this.currentRequest?.abort(); this.currentRequest?.abort();
}, 200);
} }
// Start syncing. Probably call this at startup once you have an access_token. // Start syncing. Probably call this at startup once you have an access_token.