Struct rex::manager::RexBuilder

pub struct RexBuilder<K>
where
    K: Rex,
{ /* private fields */ }

Implementations

impl<K> RexBuilder<K>

where K: Rex, K::Message: From<TimeoutInput<K>> + TryInto<TimeoutInput<K>>, <K::Message as TryInto<TimeoutInput<K>>>::Error: Send, TimeoutManager<K>: NotificationProcessor<K::Message>,

pub fn new(signal_queue: Arc<SignalQueue<K>>) -> Self

pub fn with_sm<SM: StateMachine<K> + 'static>(self, state_machine: SM) -> Self

pub fn with_np<NP: NotificationProcessor<K::Message> + 'static>( self, processor: NP ) -> Self

pub fn with_boxed_np( self, processor: Box<dyn NotificationProcessor<K::Message>> ) -> Self

pub fn with_timeout_manager( self, timeout_topic: <K::Message as RexMessage>::Topic ) -> Self

pub fn with_tick_rate(self, tick_rate: Duration) -> Self

pub fn build_and_init(self) -> (SmContext<K>, AbortHandle)