Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

M1453: Review for GetCachedMessages #4175

Closed
wants to merge 9 commits into from

sent acknowledgement of attribute change

  • Loading branch information
sam0rai9 committed Nov 24, 2014
commit 9b7e7f4d2085542313d1e847d0063ac204fcd391
@@ -90,6 +90,11 @@ impl Actor for HighlighterActor {
}
}

#[deriving(Encodable)]
struct ModifyAttributeReply{
to: String,
}

impl Actor for NodeActor {
fn name(&self) -> String {
self.name.clone()
@@ -104,7 +109,6 @@ impl Actor for NodeActor {
"modifyAttributes" => {
let target = _msg.find(&"to".to_string()).unwrap().as_string().unwrap();
let _mods = _msg.find(&"modifications".to_string()).unwrap().as_list().unwrap();

let mut modifications: Vec<Modification> = Vec::new();
for json_mod in _mods.iter() {
let modification: Modification = json::decode(json_mod.to_string().as_slice()).unwrap();
@@ -114,6 +118,10 @@ impl Actor for NodeActor {
self.script_chan.send(ModifyAttribute(self.pipeline,
_registry.actor_to_script(target.to_string()),
modifications));
let msg = ModifyAttributeReply{
to:target.to_string(),
};
stream.write_json_packet(&msg);
true
}

ProTip! Use n and p to navigate between commits in a pull request.
You can’t perform that action at this time.