Struct ServiceSends 

pub struct ServiceSends<M> { /* private fields */ }

Requests interpreted by the runtime local to the emitting actor.

Unlike crate::Delivery, a service request has no actor address. Its recipient is definitionally the interpreter of the actor whose transition emitted it. This distinct send lane lets interpreters route ordinary deliveries and local services with disjoint static implementations.

Implementations

impl<M> ServiceSends<M>

pub fn new(requests: Vec<M>) -> ServiceSends<M>

pub fn one(request: M) -> ServiceSends<M>

pub fn as_slice(&self) -> &[M]

pub fn iter(&self) -> Iter<'_, M>

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

pub fn extend(&mut self, requests: impl IntoIterator<Item = M>)

pub fn into_requests(self) -> Vec<M>

Trait Implementations

impl<M> Clone for ServiceSends<M>

where M: Clone,

fn clone(&self) -> ServiceSends<M>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<M> Debug for ServiceSends<M>

where M: Debug,

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl<M> Eq for ServiceSends<M>

where M: Eq,

impl<M> Index<usize> for ServiceSends<M>

type Output = M

The returned type after indexing.

fn index(&self, index: usize) -> &<ServiceSends<M> as Index<usize>>::Output

Performs the indexing (container[index]) operation.

impl<M> IntoIterator for ServiceSends<M>

type Item = M

The type of the elements being iterated over.

type IntoIter = IntoIter<M>

Which kind of iterator are we turning this into?

fn into_iter(self) -> <ServiceSends<M> as IntoIterator>::IntoIter

Creates an iterator from a value.

impl<'a, M> IntoIterator for &'a ServiceSends<M>

type Item = &'a M

The type of the elements being iterated over.

type IntoIter = Iter<'a, M>

Which kind of iterator are we turning this into?

fn into_iter(self) -> <&'a ServiceSends<M> as IntoIterator>::IntoIter

Creates an iterator from a value.

impl<N> ObservesCreations<N> for ServiceSends<ObserveCreation<N>>

where N: Copy + Eq,

fn observes_creation(&self, nonce: N) -> bool

Whether this algebra contains an ObserveCreation for nonce.

impl<N> ObservesCreations<N> for ServiceSends<ScheduleAt>

fn observes_creation(&self, _nonce: N) -> bool

Whether this algebra contains an ObserveCreation for nonce.

impl<N> ObservesCreations<N> for ServiceSends<ScheduleAfter>

fn observes_creation(&self, _nonce: N) -> bool

Whether this algebra contains an ObserveCreation for nonce.

impl<M, N> ObservesCreations<N> for ServiceSends<ObserveChild<M>>

fn observes_creation(&self, _nonce: N) -> bool

Whether this algebra contains an ObserveCreation for nonce.

impl<A, N> ObservesCreations<N> for ServiceSends<ObservePeer<A>>

where A: Address,

fn observes_creation(&self, _nonce: N) -> bool

Whether this algebra contains an ObserveCreation for nonce.

impl<A, N> ObservesCreations<N> for ServiceSends<UnwatchPeer<A>>

fn observes_creation(&self, _nonce: N) -> bool

Whether this algebra contains an ObserveCreation for nonce.

impl<A, N> ObservesCreations<N> for ServiceSends<ReportWorkerStopped<A>>

where A: Address,

fn observes_creation(&self, _nonce: N) -> bool

Whether this algebra contains an ObserveCreation for nonce.

impl<M, N> ObservesCreations<N> for ServiceSends<ReportWorkerCreationResolved<M>>

fn observes_creation(&self, _nonce: N) -> bool

Whether this algebra contains an ObserveCreation for nonce.

impl<M> PartialEq for ServiceSends<M>

where M: PartialEq,

fn eq(&self, other: &ServiceSends<M>) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl<M> SendAlgebra for ServiceSends<M>

fn empty() -> ServiceSends<M>

fn append(&mut self, other: ServiceSends<M>)

fn combine(self, other: Self) -> Self

fn send<Input, Path>(&mut self, input: Input)

where Self: SendInput<Input, Path>,

Append one request to its statically selected semantic lane.

fn sending<Input, Path>(input: Input) -> Self

where Self: SendInput<Input, Path>,

Build a send product containing one request in its selected lane.

impl<M> SendInput<M, Own> for ServiceSends<M>

fn emit(&mut self, input: M)

impl<M> StructuralPartialEq for ServiceSends<M>

where M: PartialEq,