pub fn start(
        derivedstreams: StoreContext<DerivedStreamSpec, C>,
        topics: StoreContext<TopicSpec, C>,
        modules: StoreContext<SmartModuleSpec, C>,
    ) -> Arc<DerivedStreamControllerStat> {
        let stat = Arc::new(DerivedStreamControllerStat::default());
        let controller = Self {
            derivedstreams,
            topics,
            modules,
            stat: stat.clone(),
        };

        spawn(controller.dispatch_loop());

        stat
    }
/// create new smart stream controller and return stat
create new smart stream controller and return stat
create new smart stream controller and return stat
pub fn start(
        derivedstreams: StoreContext<DerivedStreamSpec, C>,
        topics: StoreContext<TopicSpec, C>,
        modules: StoreContext<SmartModuleSpec, C>,
    ) -> Arc<DerivedStreamControllerStat> {
        let stat = Arc::new(DerivedStreamControllerStat::default());
        let controller = Self {
            derivedstreams,
            topics,
            modules,
            stat: stat.clone(),
        };
        spawn(controller.dispatch_loop());
        stat
    }
pub fn start ( derivedstreams : StoreContext < DerivedStreamSpec , C > , topics : StoreContext < TopicSpec , C > , modules : StoreContext < SmartModuleSpec , C > , ) -> Arc < DerivedStreamControllerStat > { let stat = Arc :: new ( DerivedStreamControllerStat :: default ( ) ) ; let controller = Self { derivedstreams , topics , modules , stat : stat . clone ( ) , } ; spawn ( controller . dispatch_loop ( ) ) ; stat }
create new smart stream controller and return stat
create new smart stream controller and return stat
derivedstreams
StoreContext<DerivedStreamSpec, C>
topics
StoreContext<TopicSpec, C>
modules
StoreContext<SmartModuleSpec, C>
derivedstreams
StoreContext<DerivedStreamSpec, C>
topics
StoreContext<TopicSpec, C>
modules
StoreContext<SmartModuleSpec, C>