Skip to main content

DelayingExecutor

Struct DelayingExecutor 

Source
pub struct DelayingExecutor<'a> {
    pub inner: &'a dyn RoundExecutor,
    pub delay: Duration,
}
Expand description

Wraps a consortium_nix::cascade::RoundExecutor and sleeps for a configurable duration inside dispatch. Critical for live demos: without this, the deterministic sim resolves a round in microseconds and the live renderer’s “spinning” frame (rendered at PlanComputed) is invisible because EdgeCompleted fires before the human eye can register it.

The sleep happens between PlanComputed (which marks targets in_progress) and EdgeCompleted (which marks them has_closure), so the spinning ⏵ glyph is visible for delay real wall-time, then snaps to ✔ on the next frame.

Demo / visualization only. Putting this in production paths adds fake latency to real deploys.

Fields§

§inner: &'a dyn RoundExecutor§delay: Duration

Trait Implementations§

Auto Trait Implementations§

§

impl<'a> !RefUnwindSafe for DelayingExecutor<'a>

§

impl<'a> !UnwindSafe for DelayingExecutor<'a>

§

impl<'a> Freeze for DelayingExecutor<'a>

§

impl<'a> Send for DelayingExecutor<'a>

§

impl<'a> Sync for DelayingExecutor<'a>

§

impl<'a> Unpin for DelayingExecutor<'a>

§

impl<'a> UnsafeUnpin for DelayingExecutor<'a>

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = !

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, !>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V