pub struct SimAtomicSender<T: Serialize + DeserializeOwned, O: Ordering, R: Retries>(/* private fields */);Available on crate feature
sim only.Expand description
A sender for an atomic input in a simulation.
The send method returns a future that resolves once the atomic tick
containing the sent item has completed processing.
Implementations§
Source§impl<T: Serialize + DeserializeOwned> SimAtomicSender<T, NoOrder, ExactlyOnce>
impl<T: Serialize + DeserializeOwned> SimAtomicSender<T, NoOrder, ExactlyOnce>
Sourcepub async fn send_many_unordered_atomic<I: IntoIterator<Item = T>>(
&self,
iter: I,
)
pub async fn send_many_unordered_atomic<I: IntoIterator<Item = T>>( &self, iter: I, )
Sends several messages into the atomic input, in non-deterministic order. Returns a future that resolves once all items have been processed through their atomic ticks.
Source§impl<T: Serialize + DeserializeOwned> SimAtomicSender<T, TotalOrder, ExactlyOnce>
impl<T: Serialize + DeserializeOwned> SimAtomicSender<T, TotalOrder, ExactlyOnce>
Sourcepub async fn send_atomic(&self, t: T)
pub async fn send_atomic(&self, t: T)
Sends a message into the atomic input and returns a future that resolves once the atomic tick containing this item has completed processing.
Sourcepub async fn send_many_atomic<I: IntoIterator<Item = T>>(&self, iter: I)
pub async fn send_many_atomic<I: IntoIterator<Item = T>>(&self, iter: I)
Sends several messages into the atomic input. Returns a future that resolves once all items have been processed through their atomic ticks.
Auto Trait Implementations§
impl<T, O, R> Freeze for SimAtomicSender<T, O, R>
impl<T, O, R> RefUnwindSafe for SimAtomicSender<T, O, R>
impl<T, O, R> Send for SimAtomicSender<T, O, R>
impl<T, O, R> Sync for SimAtomicSender<T, O, R>
impl<T, O, R> Unpin for SimAtomicSender<T, O, R>
impl<T, O, R> UnsafeUnpin for SimAtomicSender<T, O, R>
impl<T, O, R> UnwindSafe for SimAtomicSender<T, O, R>
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
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreCreates a shared type from an unshared type.
§impl<T> ToSinkBuild for T
impl<T> ToSinkBuild for T
§fn iter_to_sink_build(self) -> SendIterBuild<Self>
fn iter_to_sink_build(self) -> SendIterBuild<Self>
§fn stream_to_sink_build(self) -> SendStreamBuild<Self>where
Self: Sized + Stream,
fn stream_to_sink_build(self) -> SendStreamBuild<Self>where
Self: Sized + Stream,
Starts a [
SinkBuild] adaptor chain to send all items from self as a [Stream].