Struct WatchSends 

pub struct WatchSends<A: Address, Sends> {
    pub behavior: Sends,
    pub observations: ServiceSends<ObservePeer<A>>,
}

Named effect lanes added by Watch.

Fields

behavior: Sends

observations: ServiceSends<ObservePeer<A>>

Trait Implementations

impl<A: Clone + Address, Sends: Clone> Clone for WatchSends<A, Sends>

fn clone(&self) -> WatchSends<A, Sends>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<A: Debug + Address, Sends: Debug> Debug for WatchSends<A, Sends>

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

Formats the value using the given formatter.

impl<A: Eq + Address, Sends: Eq> Eq for WatchSends<A, Sends>

impl<A: PartialEq + Address, Sends: PartialEq> PartialEq for WatchSends<A, Sends>

fn eq(&self, other: &WatchSends<A, Sends>) -> bool

Equality operator ==.

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

Inequality operator !=.

impl<A: Address, Sends: SendAlgebra> SendAlgebra for WatchSends<A, Sends>

fn empty() -> Self

fn append(&mut self, other: Self)

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<A: Address, Sends> SendInput<ObservePeer<A>, Own> for WatchSends<A, Sends>

fn emit(&mut self, input: ObservePeer<A>)

impl<A: PartialEq + Address, Sends: PartialEq> StructuralPartialEq for WatchSends<A, Sends>