Searched refs:SharedBufferSubscription (Results 1 – 3 of 3) sorted by relevance
22 pub struct SharedBufferSubscription(Arc<Mutex<BufferSubscriptionData>>); struct30 impl SharedBufferSubscription { implementation33 SharedBufferSubscription::default() in new()66 impl Default for SharedBufferSubscription { implementation72 impl BufferSubscription for SharedBufferSubscription { implementation
17 use crate::{subscriptions::SharedBufferSubscription, *};25 subscription: SharedBufferSubscription,31 Self { config, subscriber: None, subscription: SharedBufferSubscription::new() } in new()
16 buffers::BufferPool, subscriptions::SharedBufferSubscription, BufferPublisher,24 subscription: SharedBufferSubscription,35 subscription: SharedBufferSubscription::new(), in new()