feat(node): execute_remote_method
This commit is contained in:
@@ -174,30 +174,19 @@ impl Node {
|
|||||||
.send_remote_signal(self.path.as_str(), method, data)
|
.send_remote_signal(self.path.as_str(), method, data)
|
||||||
.map_err(|_| anyhow!("Unable to write in messenger"))
|
.map_err(|_| anyhow!("Unable to write in messenger"))
|
||||||
}
|
}
|
||||||
// pub fn execute_remote_method(
|
pub fn execute_remote_method(
|
||||||
// &self,
|
&self,
|
||||||
// method: &str,
|
method: &str,
|
||||||
// data: &[u8],
|
data: &[u8],
|
||||||
// callback: Box<dyn Fn(&[u8]) + 'a>,
|
callback: Box<dyn FnOnce(&[u8]) + Send + Sync>,
|
||||||
// ) -> Result<()> {
|
) -> Result<()> {
|
||||||
// self.aliases
|
self.get_client()
|
||||||
// .get_valid_contents()
|
.messenger
|
||||||
// .iter()
|
.as_ref()
|
||||||
// .filter(|alias| alias.remote_methods.iter().any(|e| e == &method))
|
.ok_or_else(|| anyhow!("Node's client has no messenger"))?
|
||||||
// .for_each(|alias| {
|
.execute_remote_method(self.path.as_str(), method, data, callback)
|
||||||
// alias
|
.map_err(|_| anyhow!("Unable to write in messenger"))
|
||||||
// .node
|
}
|
||||||
// .upgrade()
|
|
||||||
// .unwrap()
|
|
||||||
// .execute_remote_method(method, data, callback);
|
|
||||||
// });
|
|
||||||
// self.get_client()
|
|
||||||
// .messenger
|
|
||||||
// .as_ref()
|
|
||||||
// .ok_or_else(|| anyhow!("Node's client has no messenger"))?
|
|
||||||
// .execute_remote_method(self.path.as_str(), method, data, callback)
|
|
||||||
// .map_err(|_| anyhow!("Unable to write in messenger"))
|
|
||||||
// }
|
|
||||||
}
|
}
|
||||||
|
|
||||||
#[allow(dead_code)]
|
#[allow(dead_code)]
|
||||||
|
|||||||
Reference in New Issue
Block a user