Searched refs:BufferSubscription (Results 1 – 4 of 4) sorted by relevance
38 pub fn clone_for_subscriber(&self) -> Box<dyn BufferSubscription> { in clone_for_subscriber() argument39 Box::new(self.clone()) as Box<dyn BufferSubscription> in clone_for_subscriber()72 impl BufferSubscription for SharedBufferSubscription {
35 subscription: Option<Box<dyn BufferSubscription>>,88 fn on_subscribe(&mut self, subscription: Box<dyn BufferSubscription>) { in on_subscribe() argument
69 fn on_subscribe(&mut self, subscription: Box<dyn BufferSubscription>) { in on_subscribe() argument
95 fn on_subscribe(&mut self, subscription: Box<dyn BufferSubscription>); in on_subscribe() argument149 pub trait BufferSubscription: Send + Sync + 'static { interface