Struct ReceiveTimeoutSends 

pub struct ReceiveTimeoutSends<Sends> {
    pub behavior: Sends,
    pub schedules: ServiceSends<ScheduleAfter>,
}

Named effect lanes added by ReceiveTimeout.

Fields

behavior: Sends

schedules: ServiceSends<ScheduleAfter>

Trait Implementations

impl<Sends: SendAlgebra> SendAlgebra for ReceiveTimeoutSends<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<Sends, Input, Path> SendInput<Input, Inner<Path>> for ReceiveTimeoutSends<Sends>

where Sends: SendInput<Input, Path>,

fn emit(&mut self, input: Input)

impl<Sends> SendInput<ScheduleAfter, Own> for ReceiveTimeoutSends<Sends>

fn emit(&mut self, input: ScheduleAfter)