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 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