pub struct OffsetPublisher { /* private fields */ }
Expand description
publish current offsets to listeners
Implementations§
source§impl OffsetPublisher
impl OffsetPublisher
pub fn new(initial_value: i64) -> OffsetPublisher
pub fn current_value(&self) -> i64
sourcepub fn update_increment(&self)
pub fn update_increment(&self)
increase value by 1 and notify
pub fn change_listner(self: &Arc<OffsetPublisher>) -> OffsetChangeListener
👎Deprecated: Replace by change_listener
pub fn change_listener(self: &Arc<OffsetPublisher>) -> OffsetChangeListener
Trait Implementations§
Auto Trait Implementations§
impl !Freeze for OffsetPublisher
impl RefUnwindSafe for OffsetPublisher
impl Send for OffsetPublisher
impl Sync for OffsetPublisher
impl Unpin for OffsetPublisher
impl UnwindSafe for OffsetPublisher
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