diff options
| author | Max Audron <me@audron.dev> | 2026-02-22 14:16:20 +0100 |
|---|---|---|
| committer | Max Audron <me@audron.dev> | 2026-02-22 14:16:20 +0100 |
| commit | 2af049dbab329ba049d137c7fc3a9c3aed6a780e (patch) | |
| tree | ddd5c3057404c95656e2f3b39f58db6d1d655250 /src/message/signalproxy/objects/bufferviewmanager.rs | |
| parent | NetworkList 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.rs | 12 |
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(()) } } |
