Struct NodeBridge

pub struct NodeBridge { /* private fields */ }

The Bridge between node and rust.

Implementations

impl NodeBridge

pub fn new() -> NodeBridge

Creates a bridge between node and rust. There can be only 1 bridge per rust program.

pub fn send<T: ToString, F: ToString>( &self, channel_name: T, data: F, ) -> Result<(), BridgeClosedError>

Sends a message through a channel to node. Results with an Err(BridgeClosedError) if the bridge is already closed.

assert_eq!(bridge.send("channel_foo", "bar"), Ok(()));
bridge.close().await;
assert_eq!(bridge.send("channel_foo", "bar"), Err(BridgeClosedError));

pub async fn wait_until_closes(&self)

Waits until the bridge is closed in some way to prevent it from closing on its own.

pub fn is_closed(&self) -> bool

Returns whether the bridge is closed or not.

pub async fn close(&self)

Closes the bridge and waits until its close.

pub async fn receive<T: ToString>( &self, channel_name: T, ) -> Result<String, BridgeClosedError>

Receives a message through a channel from node. Results with an Err(BridgeClosedError) if the bridge is already closed.

bridge.receive("channel_foo").await.unwrap();
bridge.close().await;
assert_eq!(bridge.receive("channel_foo").await, Err(BridgeClosedError));

pub fn register<T: ToString + 'static, D: Send + 'static + Clone, B: FromStr + 'static>( &self, name: &str, function: fn(Vec<B>, Option<D>) -> T, pass_data: Option<D>, )

where <B as FromStr>::Err: Debug,

Registers a sync function that can be called from node as long as the bridge is not closed.

pub fn register_async<T: ToString, F, D>( &self, name: &str, function: F, pass_data: Option<D>, )

where F: AsyncFn2<Vec<String>, Option<D>, Output = T> + Send + Sync + 'static, <F as AsyncFn2<Vec<String>, Option<D>>>::OutputFuture: Send, D: Send + Clone + 'static,

Registers an async function that can be called from node as long as the bridge is not closed.

Trait Implementations

impl Clone for NodeBridge

fn clone(&self) -> NodeBridge

Returns a duplicate of the value.

const fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.