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

ui: Simplify TimelineInner subscription methods

Browse Source
This commit is contained in:
Jonas Platte
2023-09-13 10:59:15 +02:00
committed by Jonas Platte
parent fa0d949600
commit a1d730f87b
1 changed files with 2 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
crates/matrix-sdk-ui/src/timeline/inner/mod.rs
View File

@@ -149,10 +149,7 @@ impl<P: RoomDataProvider> TimelineInner<P> {
) -> (Vector<Arc<TimelineItem>>, impl Stream<Item = VectorDiff<Arc<TimelineItem>>>) {
trace!("Creating timeline items signal");
let state = self.state.read().await;
// auto-deref to the inner vector's clone method
let items = state.items.clone();
let stream = state.items.subscribe().into_stream();
(items, stream)
(state.items.clone(), state.items.subscribe().into_stream())
}
pub(super) async fn subscribe_batched(
@@ -160,10 +157,7 @@ impl<P: RoomDataProvider> TimelineInner<P> {
) -> (Vector<Arc<TimelineItem>>, impl Stream<Item = Vec<VectorDiff<Arc<TimelineItem>>>>) {
trace!("Creating timeline items signal");
let state = self.state.read().await;
// auto-deref to the inner vector's clone method
let items = state.items.clone();
let stream = state.items.subscribe().into_batched_stream();
(items, stream)
(state.items.clone(), state.items.subscribe().into_batched_stream())
}
pub(super) async fn subscribe_filter_map<U, F>(