@@ -167,7 +167,7 @@ impl fmt::Debug for EventCache {
167
167
impl EventCache {
168
168
/// Create a new [`EventCache`] for the given client.
169
169
pub ( crate ) fn new ( client : WeakClient , event_cache_store : EventCacheStoreLock ) -> Self {
170
- let ( room_event_cache_generic_update_sender , _) = channel ( 32 ) ;
170
+ let ( generic_update_sender , _) = channel ( 32 ) ;
171
171
172
172
Self {
173
173
inner : Arc :: new ( EventCacheInner {
@@ -177,7 +177,7 @@ impl EventCache {
177
177
by_room : Default :: default ( ) ,
178
178
drop_handles : Default :: default ( ) ,
179
179
auto_shrink_sender : Default :: default ( ) ,
180
- room_event_cache_generic_update_sender ,
180
+ generic_update_sender ,
181
181
} ) ,
182
182
}
183
183
}
@@ -389,7 +389,7 @@ impl EventCache {
389
389
/// without side-effects, this method is recommended. Also, dropping the
390
390
/// receiver of this channel will not trigger any side-effect.
391
391
pub fn subscribe_to_room_generic_updates ( & self ) -> Receiver < RoomEventCacheGenericUpdate > {
392
- self . inner . room_event_cache_generic_update_sender . subscribe ( )
392
+ self . inner . generic_update_sender . subscribe ( )
393
393
}
394
394
}
395
395
@@ -427,7 +427,7 @@ struct EventCacheInner {
427
427
///
428
428
/// See doc comment of [`RoomEventCacheGenericUpdate`] and
429
429
/// [`EventCache::subscribe_to_room_generic_updates`].
430
- room_event_cache_generic_update_sender : Sender < RoomEventCacheGenericUpdate > ,
430
+ generic_update_sender : Sender < RoomEventCacheGenericUpdate > ,
431
431
}
432
432
433
433
type AutoShrinkChannelPayload = OwnedRoomId ;
@@ -612,7 +612,7 @@ impl EventCacheInner {
612
612
pagination_status,
613
613
room_id. to_owned ( ) ,
614
614
auto_shrink_sender,
615
- self . room_event_cache_generic_update_sender . clone ( ) ,
615
+ self . generic_update_sender . clone ( ) ,
616
616
) ;
617
617
618
618
by_room_guard. insert ( room_id. to_owned ( ) , room_event_cache. clone ( ) ) ;
@@ -621,7 +621,7 @@ impl EventCacheInner {
621
621
// emit a generic update.
622
622
if timeline_is_not_empty {
623
623
let _ = self
624
- . room_event_cache_generic_update_sender
624
+ . generic_update_sender
625
625
. send ( RoomEventCacheGenericUpdate { room_id : room_id. to_owned ( ) } ) ;
626
626
}
627
627
0 commit comments