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