From 804d097a18000e8ae3ece82a1b513b2d6eddd196 Mon Sep 17 00:00:00 2001 From: Timo Date: Sat, 22 Aug 2020 22:02:32 +0200 Subject: [PATCH] fix: wake up /sync for typing events --- src/database.rs | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/database.rs b/src/database.rs index eb27325f..7bbb6dd7 100644 --- a/src/database.rs +++ b/src/database.rs @@ -129,7 +129,6 @@ impl Database { pub async fn watch(&self, user_id: &UserId, device_id: &DeviceId) { let userid_bytes = user_id.to_string().as_bytes().to_vec(); - let mut userid_prefix = userid_bytes.clone(); userid_prefix.push(0xff); @@ -153,7 +152,8 @@ impl Database { // Events for rooms we are in for room_id in self.rooms.rooms_joined(user_id).filter_map(|r| r.ok()) { - let mut roomid_prefix = room_id.to_string().as_bytes().to_vec(); + let roomid_bytes = room_id.to_string().as_bytes().to_vec(); + let mut roomid_prefix = roomid_bytes.clone(); roomid_prefix.push(0xff); // PDUs @@ -164,7 +164,7 @@ impl Database { self.rooms .edus .roomid_lastroomactiveupdate - .watch_prefix(&roomid_prefix), + .watch_prefix(&roomid_bytes), ); futures.push(