@@ -48,7 +48,7 @@ use ruma::{
4848 room_version_rules:: RoomVersionRules ,
4949 serde:: Raw ,
5050} ;
51- use tokio:: sync:: broadcast:: { Receiver , Sender } ;
51+ use tokio:: sync:: broadcast:: Sender ;
5252use tracing:: { debug, error, instrument, trace, warn} ;
5353
5454use super :: {
@@ -361,34 +361,6 @@ impl<'a> RoomEventCacheStateLockReadGuard<'a> {
361361 EventCacheStoreLockGuard :: is_dirty ( & self . store )
362362 }
363363
364- /// Subscribe to the lazily initialized pinned event cache for this
365- /// room.
366- ///
367- /// This is a persisted view over the pinned events of a room. The
368- /// pinned events will be initially loaded from a network
369- /// request to fetch the latest pinned events will be performed,
370- /// to update it as needed. The list of pinned events will also
371- /// be kept up-to-date as new events are pinned, and new related
372- /// events show up from sync or backpagination.
373- ///
374- /// This requires the room's event cache to be initialized.
375- pub async fn subscribe_to_pinned_events (
376- & self ,
377- weak_room : & WeakRoom ,
378- ) -> Result < ( Vec < Event > , Receiver < TimelineVectorDiffs > ) , EventCacheError > {
379- let pinned_events_cache = self . state . pinned_events_cache . get_or_try_init ( || {
380- PinnedEventsCache :: new (
381- weak_room,
382- self . own_user_id . clone ( ) ,
383- self . room_version_rules . clone ( ) ,
384- self . state . linked_chunk_update_sender . clone ( ) ,
385- self . state . store . clone ( ) ,
386- )
387- } ) ?;
388-
389- pinned_events_cache. subscribe ( ) . await
390- }
391-
392364 /// Get an event-focused cache for this event and thread mode, if it
393365 /// exists.
394366 ///
0 commit comments