jellyflow-runtime 0.1.0

Headless store, rules, schema, profile, and change pipeline for Jellyflow.
Documentation 
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

use std::cell::RefCell;
use std::rc::Rc;

use super::dispatch::{dispatch_gesture_callbacks, dispatch_store_event_callbacks};
use super::traits::NodeGraphCallbacks;
use crate::runtime::events::SubscriptionToken;
use crate::runtime::store::NodeGraphStore;

/// Installs callbacks into a store via a subscription.
pub fn install_callbacks(
    store: &mut NodeGraphStore,
    callbacks: impl NodeGraphCallbacks,
) -> SubscriptionToken {
    let callbacks: Rc<RefCell<Box<dyn NodeGraphCallbacks>>> =
        Rc::new(RefCell::new(Box::new(callbacks)));
    let event_callbacks = callbacks.clone();
    let token = store.subscribe(move |ev| {
        let mut callbacks = event_callbacks.borrow_mut();
        dispatch_store_event_callbacks(callbacks.as_mut(), ev);
    });

    let gesture_callbacks = callbacks;
    store.subscribe_gesture_with_token(token, move |ev| {
        let mut callbacks = gesture_callbacks.borrow_mut();
        dispatch_gesture_callbacks(callbacks.as_mut(), ev);
    });
    token
}