Struct EventRxBuilder 

pub struct EventRxBuilder<T> { /* private fields */ }

Implementations

impl<T: Owned> EventRxBuilder<T>

pub fn new(spec: InterfaceEvent<T>, object_path: String) -> Self

pub fn inline<'a>( self, setup: &'a RoleSetup<'a>, event_handler: impl FnMut(EndpointAddr, T) + 'static, ) -> InlineRxRouterSetup<'a, impl FnMut(EndpointAddr, &Packet) + 'static>

pub fn inline_lazy<'a>( self, setup: &'a RoleSetup<'a>, event_handler: impl FnMut(EndpointAddr, T::Lazy<'_>) + 'static, ) -> InlineRxRouterSetup<'a, impl FnMut(EndpointAddr, &Packet) + 'static>

pub fn inline_untyped<'a>( self, setup: &'a RoleSetup<'a>, event_handler: impl FnMut(EndpointAddr, &Packet) + 'static, ) -> InlineRxRouterSetup<'a, impl FnMut(EndpointAddr, &Packet) + 'static>

pub fn route_to_local_queue<'a>( self, setup: &'a RoleSetup<'a>, handler: impl FnMut(EndpointAddr, &Packet) -> Option<Sender<Packet>> + 'static, )

pub fn route_to_worker<'a>( self, setup: &'a RoleSetup<'a>, handler: impl FnMut(EndpointAddr, &Packet) -> Option<WorkerId> + 'static, )

pub fn queued<'a>( self, setup: &'a RoleSetup<'a>, handler: impl AsyncFnMut(EndpointAddr, T::Lazy<'_>) + 'static, ) -> QueuedEventRxRouterSetup<'a>

pub fn queued_untyped<'a>( self, setup: &'a RoleSetup<'a>, event_handler: impl AsyncFnMut(EndpointAddr, Packet) + 'static, ) -> QueuedEventRxRouterSetup<'a>

pub fn proxy_load_balance(self, setup: &RoleSetup<'_>)

Trait Implementations

impl<T> Clone for EventRxBuilder<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.