Struct RoundsRouterBuilder

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

Builds RoundsRouter

Implementations

impl<M> RoundsRouterBuilder<M>

where M: ProtocolMessage + 'static,

pub fn new() -> Self

Constructs RoundsRouterBuilder

Alias to RoundsRouter::builder

pub fn add_round<R>(&mut self, message_store: R) -> Round<R>

where R: MessagesStore + Send + 'static, R::Output: Send, R::Error: Send, M: RoundMessage<R::Msg>,

Registers new round

Panics

Panics if round R was already registered

pub fn listen<S, E>(self, incomings: S) -> RoundsRouter<M, S>

where S: Stream<Item = Result<Incoming<M>, E>>,

Builds RoundsRouter

Takes a stream of incoming messages which will be routed between registered rounds

Trait Implementations

impl<M> Default for RoundsRouterBuilder<M>

where M: ProtocolMessage + 'static,

fn default() -> Self

Returns the “default value” for a type.