Function mmids_core::reactors::start_reactor
source · pub fn start_reactor(
name: Arc<String>,
executor: Box<dyn ReactorExecutor>,
event_hub_subscriber: UnboundedSender<SubscriptionRequest>,
update_interval: Duration
) -> UnboundedSender<ReactorRequest>