Struct OutcomeFeed 

pub struct OutcomeFeed { /* private fields */ }

Receiver side of a backend’s own outcome stream.

Cloning hands out another view of the same queue, and a view takes each fact at most once, so exactly one consumer settles a given task however many drains are alive. That is why this is a queue and not a channel: a backend outlives its first drain, and a receiver handed to a consumer that then died would leave the stream un-drainable.

Implementations

impl OutcomeFeed

pub fn channel() -> (OutcomeSink, Self)

The paired ends of one outcome stream.

pub fn try_recv(&self) -> Option<SessionOutcome>

The next fact, without waiting.

pub fn recv_timeout(&self, timeout: Duration) -> Option<SessionOutcome>

The next fact, waiting at most timeout.

Trait Implementations

impl Clone for OutcomeFeed

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for OutcomeFeed

fn default() -> Self

Returns the “default value” for a type.