Enum LossyDelayedForever

Source

pub enum LossyDelayedForever {}

Expand description

A TCP failure policy that treats dropped messages as indefinitely delayed.

Unlike Lossy, this does not require a NonDet annotation because the output stream is always lower in the partial order than the ideal stream (dropped messages are modeled as infinite delays). The tradeoff is that the output has NoOrder guarantees, imposing stricter conditions on downstream consumers.

When using this mode in the Hydro simulator, you must call .test_safety_only() because the simulator models dropped messages as indefinitely delayed, which only tests safety properties (not liveness).

LossyDelayedForever

Enum LossyDelayedForever Copy item path

Trait Implementations§

impl TcpFailPolicy for LossyDelayedForever

type OrderingGuarantee = NoOrder

fn tcp_fault() -> TcpFault

Auto Trait Implementations§

impl Freeze for LossyDelayedForever

impl RefUnwindSafe for LossyDelayedForever

impl Send for LossyDelayedForever

impl Sync for LossyDelayedForever

impl Unpin for LossyDelayedForever

impl UnsafeUnpin for LossyDelayedForever

impl UnwindSafe for LossyDelayedForever

Blanket Implementations§

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

fn type_id(&self) -> TypeId

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

fn borrow(&self) -> &T

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

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

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self> ⓘ

fn in_current_span(self) -> Instrumented<Self> ⓘ

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

fn into(self) -> U

impl<T> IntoEither for T

fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘwhere F: FnOnce(&Self) -> bool,

impl<Unshared, Shared> IntoShared<Shared> for Unsharedwhere Shared: FromUnshared<Unshared>,

fn into_shared(self) -> Shared

impl<T> Same for T

type Output = T

impl<T> ToSinkBuild for T

fn iter_to_sink_build(self) -> SendIterBuild<Self>where Self: Sized + Iterator,

fn stream_to_sink_build(self) -> SendStreamBuild<Self>where Self: Sized + Stream,

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

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

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

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

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

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

fn vzip(self) -> V

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘwhere S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self> ⓘ

Enum LossyDelayedForever

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

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

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

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

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
where F: FnOnce(&Self) -> bool,

impl<Unshared, Shared> IntoShared<Shared> for Unshared
where Shared: FromUnshared<Unshared>,

fn iter_to_sink_build(self) -> SendIterBuild<Self>
where Self: Sized + Iterator,

fn stream_to_sink_build(self) -> SendStreamBuild<Self>
where Self: Sized + Stream,

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

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

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

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘ
where S: Into<Dispatch>,