Struct SourceSet 

pub struct SourceSet<S>(/* private fields */);

A composable collection of message sources (intervals and streams) for an actor.

Sources added earlier in the chain have higher polling priority. If an earlier source is consistently ready, later sources may be starved. In practice this rarely matters for intervals and moderate-throughput streams, but keep it in mind when combining a high-throughput stream with other sources.

Implementations

impl<M: Send + 'static> SourceSet<NoStream<M>>

pub fn new() -> Self

impl<S> SourceSet<S>

pub fn interval<F, M>( self, interval: Interval, f: F, ) -> SourceSet<Merge<S, IntervalStream<F>>>

where F: Fn() -> M + Send + Unpin + 'static,

pub fn stream<S2>(self, stream: S2) -> SourceSet<Merge<S, S2>>

Trait Implementations

impl<M: Send + 'static> Default for SourceSet<NoStream<M>>

fn default() -> Self

Returns the “default value” for a type.

impl<S> Stream for SourceSet<S>

where S: Stream + Unpin,

type Item = <S as Stream>::Item

Values yielded by the stream.

fn poll_next( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Option<S::Item>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.