juiz_core 0.0.9

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
27
28
29
30
31
32

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
}