Struct fluvio_sc_schema::store::event::EventPublisher
source · pub struct EventPublisher { /* private fields */ }
Expand description
Track publishing of events by using u64 counter
Implementations§
source§impl EventPublisher
impl EventPublisher
pub fn new() -> EventPublisher
pub fn current_change(&self) -> i64
sourcepub fn store_change(&self, value: i64)
pub fn store_change(&self, value: i64)
stores new value and notifies any listeners
pub fn listen(&self) -> Pin<Box<EventListener>>
Trait Implementations§
source§impl Debug for EventPublisher
impl Debug for EventPublisher
source§impl Default for EventPublisher
impl Default for EventPublisher
source§fn default() -> EventPublisher
fn default() -> EventPublisher
Returns the “default value” for a type. Read more
Auto Trait Implementations§
impl !Freeze for EventPublisher
impl RefUnwindSafe for EventPublisher
impl Send for EventPublisher
impl Sync for EventPublisher
impl Unpin for EventPublisher
impl UnwindSafe for EventPublisher
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