aboutsummaryrefslogtreecommitdiff
path: root/src/message/signalproxy/objects/bufferviewmanager.rs
diff options
context:
space:
mode:
authorMax Audron <me@audron.dev>2026-02-22 14:16:20 +0100
committerMax Audron <me@audron.dev>2026-02-22 14:16:20 +0100
commit2af049dbab329ba049d137c7fc3a9c3aed6a780e (patch)
treeddd5c3057404c95656e2f3b39f58db6d1d655250 /src/message/signalproxy/objects/bufferviewmanager.rs
parentNetworkList and signalproxy objects error handling (diff)
add error for unkown sync message slot_name
Diffstat (limited to 'src/message/signalproxy/objects/bufferviewmanager.rs')
-rw-r--r--src/message/signalproxy/objects/bufferviewmanager.rs12
1 files changed, 7 insertions, 5 deletions
diff --git a/src/message/signalproxy/objects/bufferviewmanager.rs b/src/message/signalproxy/objects/bufferviewmanager.rs
index 1ecac4c..341fec2 100644
--- a/src/message/signalproxy/objects/bufferviewmanager.rs
+++ b/src/message/signalproxy/objects/bufferviewmanager.rs
@@ -10,6 +10,7 @@ use crate::message::StatefulSyncableServer;
use crate::message::{NetworkMap, Syncable};
use crate::primitive::{Variant, VariantList, VariantMap};
+use crate::ProtocolError;
use crate::Result;
use super::BufferViewConfig;
@@ -94,7 +95,7 @@ impl StatefulSyncableClient for BufferViewManager {
self.add_buffer_view_config(msg.params.remove(0).try_into()?)
}
"deleteBufferViewConfig" => self.delete_buffer_view_config(msg.params.remove(0).try_into()?),
- _ => Ok(()),
+ unknown => Err(ProtocolError::UnknownMsgSlotName(unknown.to_string())),
}
}
}
@@ -108,23 +109,24 @@ impl StatefulSyncableServer for BufferViewManager {
match msg.slot_name.as_str() {
"requestCreateBufferView" => self.add_buffer_view_config(BufferViewConfig::from_network_map(
&mut msg.params.remove(0).try_into()?,
- ))?,
+ )),
"requestCreateBufferViews" => {
let views: VariantList = msg.params.remove(0).try_into()?;
for view in views.into_iter() {
self.add_buffer_view_config(BufferViewConfig::from_network_map(&mut view.try_into()?))?
}
+ Ok(())
}
- "requestDeleteBufferView" => self.delete_buffer_view_config(msg.params.remove(0).try_into()?)?,
+ "requestDeleteBufferView" => self.delete_buffer_view_config(msg.params.remove(0).try_into()?),
"requestDeleteBufferViews" => {
let ids: VariantList = msg.params.remove(0).try_into()?;
for id in ids.into_iter() {
self.delete_buffer_view_config(id.try_into()?)?
}
+ Ok(())
}
- _ => (),
+ unknown => Err(ProtocolError::UnknownMsgSlotName(unknown.to_string())),
}
- Ok(())
}
}