Struct SubscriberServerHandle 

pub struct SubscriberServerHandle<Type, Event, Callback>
where
    Event: SubscriberEvent,
    Type: SubscriberEventType,
    Callback: SubscriberCallback<Event>,
{ /* private fields */ }

Implementations

impl<Type, Event, Callback> SubscriberServerHandle<Type, Event, Callback>

where Event: SubscriberEvent<Type = Type>, Type: SubscriberEventType + 'static, Callback: SubscriberCallback<Event>,

pub fn new<Config, Sub, Error>( server: SubscriberServer<Type, Event, Config, Sub>, rt: &Handle, ) -> Self

where Config: SubscriberConfig + 'static, Error: SubscriberError, Sub: Subscriber<Event, Error> + 'static, Receiver<Callback>: Send + 'static, Receiver<Event>: Send + 'static,

pub fn split( self, ) -> (EventHandle<Event>, SubscribeHandle<Type, Callback>, JoinHandle<()>)

pub fn stop_handle(&self)

This does not stop the process, you need to kill it first

pub async fn send(&mut self, event: Event) -> Result<(), SendError>

pub async fn subscribe( &mut self, event_type: Type, callback: Callback, ) -> Result<(), SendError>