From a1d730f87b2402927e44ddefdabe69e1eb1d3fab Mon Sep 17 00:00:00 2001 From: Jonas Platte Date: Wed, 13 Sep 2023 10:59:15 +0200 Subject: [PATCH] ui: Simplify TimelineInner subscription methods --- crates/matrix-sdk-ui/src/timeline/inner/mod.rs | 10 ++-------- 1 file changed, 2 insertions(+), 8 deletions(-) diff --git a/crates/matrix-sdk-ui/src/timeline/inner/mod.rs b/crates/matrix-sdk-ui/src/timeline/inner/mod.rs index cfbe81bb8..dcba3358e 100644 --- a/crates/matrix-sdk-ui/src/timeline/inner/mod.rs +++ b/crates/matrix-sdk-ui/src/timeline/inner/mod.rs @@ -149,10 +149,7 @@ impl TimelineInner

{ ) -> (Vector>, impl Stream>>) { 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 TimelineInner

{ ) -> (Vector>, impl Stream>>>) { 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(