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

ffi: Use batched timeline subscription

Browse Source
This commit is contained in:
Jonas Platte
2023-08-01 10:56:19 +02:00
committed by Jonas Platte
parent 9a8c6249bb
commit 640e5fbacf
2 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
bindings/matrix-sdk-ffi/src/room.rs
View File

@@ -241,13 +241,15 @@ impl Room {
})
.clone();
let (timeline_items, timeline_stream) = timeline.subscribe().await;
let (timeline_items, timeline_stream) = timeline.subscribe_batched().await;
let timeline_stream = TaskHandle::new(RUNTIME.spawn(async move {
pin_mut!(timeline_stream);
while let Some(diff) = timeline_stream.next().await {
listener.on_update(Arc::new(TimelineDiff::new(diff)));
while let Some(diffs) = timeline_stream.next().await {
listener.on_update(
diffs.into_iter().map(|d| Arc::new(TimelineDiff::new(d))).collect(),
);
}
}));

2
bindings/matrix-sdk-ffi/src/timeline.rs
View File

@@ -53,7 +53,7 @@ pub fn message_event_content_from_markdown(md: String) -> Arc<RoomMessageEventCo
#[uniffi::export(callback_interface)]
pub trait TimelineListener: Sync + Send {
fn on_update(&self, diff: Arc<TimelineDiff>);
fn on_update(&self, diff: Vec<Arc<TimelineDiff>>);
}
#[derive(Clone, uniffi::Object)]