Struct RexBuilder 

pub struct RexBuilder<K, In = (), Out = ()>
where
    K: Rex,
{ /* private fields */ }

Implementations

impl<K: Rex> RexBuilder<K, (), ()>

pub fn new() -> Self

impl<K, In, Out> RexBuilder<K, In, Out>

where K: Rex + Timeout, K::Message: TimeoutMessage<K>, TimeoutManager<K>: NotificationProcessor<K::Message>,

pub fn ctx(&self) -> BuilderContext<K>

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 push_np<NP: NotificationProcessor<K::Message> + 'static>( &mut self, processor: NP, )

pub fn with_ctx_np<NP: NotificationProcessor<K::Message> + 'static>( self, op: impl FnOnce(BuilderContext<K>) -> NP, ) -> Self

pub fn push_ctx_np<NP: NotificationProcessor<K::Message> + 'static>( &mut self, op: impl FnOnce(BuilderContext<K>) -> NP, )

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

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

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

pub fn build(self) -> EmptyContext<K>

pub fn build_with_handle(self, join_set: &mut JoinSet<()>) -> EmptyContext<K>

impl<K> RexBuilder<K, K::In, K::Out>

where K: Rex + Timeout + Ingress, K::Message: TimeoutMessage<K> + TryInto<K::Out, Error = Report<ConversionError>>, K::Input: TryFrom<K::In, Error = Report<ConversionError>>, TimeoutManager<K>: NotificationProcessor<K::Message>,

pub fn new_connected( outbound_tx: UnboundedSender<K::Out>, ) -> (UnboundedSender<K::In>, Self)

pub fn ingress_tx(&self) -> UnboundedSender<K::In>

pub fn with_ingress_adapter( self, state_routers: Vec<BoxedStateRouter<K, K::In>>, ingress_topic: <K::Message as RexMessage>::Topic, ) -> Self

Trait Implementations

impl<K, In, Out> Default for RexBuilder<K, In, Out>

where K: Rex,

fn default() -> Self

Returns the “default value” for a type.