astatin3/unshell
1
0
Fork 0
mirror of https://github.com/Astatin3/unshell.git synced 2026-06-08 22:38:01 -06:00
Code Issues Packages Projects Releases Wiki Activity

Reduce hook table public surface

Browse Source
This commit is contained in:
Michael Mikovsky
2026-04-30 10:15:54 -06:00
parent 71b311065d
commit 7c0ee31d38
2 changed files with 4 additions and 24 deletions
Download Patch File Download Diff File Expand all files Collapse all files
unshell-leaves/src/lib.rs
+2 -1
View File
@@ -29,13 +29,14 @@ pub use unshell_protocol as protocol;
/// use unshell_leaves::role_leaf; /// use unshell_leaves::role_leaf;
/// mod endpoint { pub struct DemoEndpoint; } /// mod endpoint { pub struct DemoEndpoint; }
/// mod tui { pub struct DemoTui; } /// mod tui { pub struct DemoTui; }
/// # #[cfg(not(all(feature = "leaf_endpoint", feature = "leaf_tui")))]
/// role_leaf! { /// role_leaf! {
/// pub type DemoLeaf { /// pub type DemoLeaf {
/// endpoint => endpoint::DemoEndpoint, /// endpoint => endpoint::DemoEndpoint,
/// tui => tui::DemoTui, /// tui => tui::DemoTui,
/// } /// }
/// } /// }
/// # #[cfg(feature = "leaf_endpoint")] /// # #[cfg(all(feature = "leaf_endpoint", not(feature = "leaf_tui")))]
/// # let _ = core::marker::PhantomData::<DemoLeaf>; /// # let _ = core::marker::PhantomData::<DemoLeaf>;
/// ``` /// ```
#[macro_export] #[macro_export]
unshell-protocol/src/protocol/tree/hook.rs
+2 -23
View File
@@ -365,27 +365,6 @@ impl HookTable {
self.active.get(key) self.active.get(key)
} }
/// Returns the mutable active hook for `key`, if present.
///
/// # Example
/// ```rust
/// use unshell::protocol::tree::{ActiveHook, HookKey, HookTable};
/// let mut hooks = HookTable::default();
/// let key = HookKey::new(vec!["root".into()], 1);
/// hooks.insert_active(key.clone(), ActiveHook {
/// peer_path: vec!["worker".into()],
/// procedure_id: "example.service.v1.invoke".into(),
/// local_ended: false,
/// peer_ended: false,
/// })?;
/// hooks.active_mut(&key).unwrap().peer_ended = true;
/// assert!(hooks.active(&key).unwrap().peer_ended);
/// # Ok::<(), unshell::protocol::tree::HookConflict>(())
/// ```
pub fn active_mut(&mut self, key: &HookKey) -> Option<&mut ActiveHook> {
self.active.get_mut(key)
}
/// Resolves an active hook from either side of the conversation. /// Resolves an active hook from either side of the conversation.
/// ///
/// The host side addresses hooks directly by `(return_path, hook_id)`. Peer-originated /// The host side addresses hooks directly by `(return_path, hook_id)`. Peer-originated
@@ -447,7 +426,7 @@ impl HookTable {
/// # Ok::<(), unshell::protocol::tree::HookConflict>(()) /// # Ok::<(), unshell::protocol::tree::HookConflict>(())
/// ``` /// ```
pub fn mark_local_end(&mut self, key: &HookKey) -> bool { pub fn mark_local_end(&mut self, key: &HookKey) -> bool {
let Some(active) = self.active_mut(key) else { let Some(active) = self.active.get_mut(key) else {
return false; return false;
}; };
active.local_ended = true; active.local_ended = true;
@@ -474,7 +453,7 @@ impl HookTable {
/// # Ok::<(), unshell::protocol::tree::HookConflict>(()) /// # Ok::<(), unshell::protocol::tree::HookConflict>(())
/// ``` /// ```
pub fn mark_peer_end(&mut self, key: &HookKey) -> bool { pub fn mark_peer_end(&mut self, key: &HookKey) -> bool {
let Some(active) = self.active_mut(key) else { let Some(active) = self.active.get_mut(key) else {
return false; return false;
}; };
active.peer_ended = true; active.peer_ended = true;