Split incoming large .resets into a reset + append in order to quicker update the UI

This commit is contained in:
Stefan Ceriu 2023-08-22 15:23:28 +03:00 committed by Stefan Ceriu
parent 4c33d9a414
commit 7b9f6d253e

View File

@ -133,25 +133,36 @@ class RoomSummaryProvider: RoomSummaryProviderProtocol {
MXLog.info("\(name): Received \(diffs.count) diffs, current room list \(rooms.compactMap { $0.id ?? "Empty" })")
rooms = diffs
.reduce(rooms) { currentItems, diff in
guard let collectionDiff = buildDiff(from: diff, on: currentItems) else {
MXLog.error("\(name): Failed building CollectionDifference from \(diff)")
return currentItems
}
guard let updatedItems = currentItems.applying(collectionDiff) else {
MXLog.error("\(name): Failed applying diff: \(collectionDiff)")
return currentItems
}
return updatedItems
for diff in diffs {
// Special case resets in order to prevent large updates from blocking the UI
// Render the first resetDiffChunkingThreshhold as a reset and then append the rest to give the UI time to update
let resetDiffChunkingThreshhold = 50
if case .reset(let values) = diff, values.count > resetDiffChunkingThreshhold {
processDiff(RoomListEntriesUpdate.reset(values: Array(values[..<resetDiffChunkingThreshhold])))
processDiff(RoomListEntriesUpdate.append(values: Array(values.dropFirst(resetDiffChunkingThreshhold))))
} else {
processDiff(diff)
}
}
detectDuplicatesInRoomList(rooms)
MXLog.info("\(name): Finished applying \(diffs.count) diffs, new room list \(rooms.compactMap { $0.id ?? "Empty" })")
}
private func processDiff(_ diff: RoomListEntriesUpdate) {
guard let collectionDiff = buildDiff(from: diff, on: rooms) else {
MXLog.error("\(name): Failed building CollectionDifference from \(diff)")
return
}
guard let updatedItems = rooms.applying(collectionDiff) else {
MXLog.error("\(name): Failed applying diff: \(collectionDiff)")
return
}
rooms = updatedItems
}
private func fetchRoomInfo(roomListItem: RoomListItemProtocol) -> RoomInfo? {
class FetchResult {