mirror/matrix-rust-sdk
1
0
Fork 0
mirror of https://github.com/matrix-org/matrix-rust-sdk.git synced 2026-05-07 23:44:53 -04:00
Code Issues Packages Projects Releases Wiki Activity

chore: Add some inline documentation.

Browse Source
This commit is contained in:
Ivan Enderlin
2023-03-08 12:01:57 +01:00
parent 7369010964
commit 66d4ced90f
1 changed files with 12 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
crates/matrix-sdk/src/sliding_sync/mod.rs
View File

@@ -1070,6 +1070,15 @@ impl SlidingSync {
#[cfg(not(feature = "e2e-encryption"))]
let response = request.await?;
// At this point, the request has been sent, and a response has been received.
//
// We must ensure the handling of the response cannot be stopped/
// cancelled. It must be done entirely, otherwise we can have
// corrupted/incomplete states for Sliding Sync and other parts of
// the code.
//
// That's why we are running the handling of the response in a blocking
// mode since it cannot be cancelled abruptly.
debug!("Sliding sync response received");
match &response.txn_id {
@@ -1088,8 +1097,6 @@ impl SlidingSync {
_ => {}
}
debug!("Sliding sync response has been processed");
// Handle and transform a Sliding Sync Response to a `SyncResponse`.
//
// We may not need the `sync_response` in the future (once `SyncResponse` will
@@ -1097,6 +1104,9 @@ impl SlidingSync {
// `sliding_sync_response` is vital, so it must be done somewhere; for now it
// happens here.
let sync_response = self.client.process_sliding_sync(&response).await?;
debug!("Sliding sync response has been processed");
let updates = self.handle_response(response, sync_response, list_generators)?;
self.cache_to_storage().await?;