pub struct PubSubSystem { /* private fields */ }Implementations§
Source§impl PubSubSystem
impl PubSubSystem
pub fn new(buffer_size: usize) -> Self
pub fn publish(&self, event: ChangeEvent) -> Result<()>
pub fn listen(&self, collection: impl Into<String>) -> ChangeListener
pub fn listen_all(&self) -> ChangeListener
pub fn listener_count(&self, collection: &str) -> usize
pub fn total_listeners(&self) -> usize
Trait Implementations§
Auto Trait Implementations§
impl Freeze for PubSubSystem
impl !RefUnwindSafe for PubSubSystem
impl Send for PubSubSystem
impl Sync for PubSubSystem
impl Unpin for PubSubSystem
impl !UnwindSafe for PubSubSystem
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more