juiz_core 0.0.4

Core library for JUIZ application. This package is not required if you want to build juiz functional module.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26

use crate::prelude::*;





pub(super) fn setup_subscribe_topic(system: &System, process: ProcessPtr, arg_name: &String, sub_topic_info: TopicManifest) -> JuizResult<()> {
    log::trace!("setup_subscrie_topic(process, {arg_name}, {sub_topic_info:?}) called");
    let _topic_name = sub_topic_info.name.as_str();
    let r = system.core_broker().lock_mut().and_then(|mut cb| {
        let _id = process.identifier();
        cb.worker_mut().process_subscribe_topic(process, arg_name, sub_topic_info)
    } );
    r
    
}

pub(super) fn setup_publish_topic(system: &System, process: ProcessPtr, pub_topic_info: TopicManifest) -> JuizResult<()> {
    log::trace!("setup_publish_topic(process, {pub_topic_info:?}) called");
    let _topic_name = pub_topic_info.name.as_str();
    let r = system.core_broker().lock_mut().and_then(|mut cb| {
        let _id = process.identifier();
        cb.worker_mut().process_publish_topic(process, pub_topic_info)
    } );
    r
}