pub fn advance_epoch(&mut self, next: T) -> Result<(), Error> {
        if !self.now_at.less_equal(&next) {
            // We can't rewind time.
            Err(Error::conflict(format!(
                "Domain is at {:?}, you attempted to rewind to {:?}.",
                &self.now_at, &next
            )))
        } else if !self.now_at.eq(&next) {
            trace!("Advancing domain epoch to {:?} ", next);

            for handle in self.input_sessions.values_mut() {
                handle.advance_to(next.clone());
                handle.flush();
            }
            self.now_at = next;

            Ok(())
        } else {
            Ok(())
        }
    }
/// Advances the domain epoch. The domain epoch can be in advance
/// of or lag behind the domain frontier. It is used by timeless
/// attributes to avoid stalling timeful inputs.
Advances the domain epoch. The domain epoch can be in advance
of or lag behind the domain frontier. It is used by timeless
attributes to avoid stalling timeful inputs.
Advances the domain epoch . The domain epoch can be in advance of or lag behind the domain frontier . It is used by timeless attributes to avoid stalling timeful inputs .
pub fn advance_epoch(&mut self, next: T) -> Result<(), Error> {
        if !self.now_at.less_equal(&next) {
            // We can't rewind time.
            Err(Error::conflict(format!(
                "Domain is at {:?}, you attempted to rewind to {:?}.",
                &self.now_at, &next
            )))
        } else if !self.now_at.eq(&next) {
            trace!("Advancing domain epoch to {:?} ", next);
            for handle in self.input_sessions.values_mut() {
                handle.advance_to(next.clone());
                handle.flush();
            }
            self.now_at = next;
            Ok(())
        } else {
            Ok(())
        }
    }
pub fn advance_epoch ( & mut self , next : T ) -> Result < ( ) , Error > { if ! self . now_at . less_equal ( & next ) { // We can't rewind time. Err ( Error :: conflict ( format ! ( " " self now_at next ) ) ) } else if ! self . now_at . eq ( & next ) { trace ! ( " " next ) ; for handle in self . input_sessions . values_mut ( ) { handle . advance_to ( next . clone ( ) ) ; handle . flush ( ) ; } self . now_at = next ; Ok ( ( ) ) } else { Ok ( ( ) ) } }
Advances the domain epoch.
Advances the domain epoch .
&mut self
next
T
&mut self
next
T