From 38713a8e628740007a811c70cdc26aa31897339b Mon Sep 17 00:00:00 2001 From: Fintan Halpenny Date: Fri, 13 Feb 2026 08:24:47 +0000 Subject: [PATCH] protocol/service: drop `chan` qualifier Small refactor to drop the `chan` qualifier and use `Sender` directly. --- .../radicle-protocol/src/service/command.rs | 24 +++++++++---------- 1 file changed, 12 insertions(+), 12 deletions(-) diff --git a/crates/radicle-protocol/src/service/command.rs b/crates/radicle-protocol/src/service/command.rs index 13b9d6d9..be2cab22 100644 --- a/crates/radicle-protocol/src/service/command.rs +++ b/crates/radicle-protocol/src/service/command.rs @@ -1,6 +1,6 @@ use std::{collections::HashSet, fmt, sync::Arc, time}; -use crossbeam_channel as chan; +use crossbeam_channel::Sender; use radicle::crypto::PublicKey; use radicle::node::policy::config as policy; use radicle::node::policy::Scope; @@ -20,34 +20,34 @@ pub type QueryState = dyn Fn(&dyn ServiceState) -> Result<(), CommandError> + Se /// Commands sent to the service by the operator. pub enum Command { /// Announce repository references for given repository and namespaces to peers. - AnnounceRefs(RepoId, HashSet, chan::Sender), + AnnounceRefs(RepoId, HashSet, Sender), /// Announce local repositories to peers. AnnounceInventory, /// Add repository to local inventory. - AddInventory(RepoId, chan::Sender), + AddInventory(RepoId, Sender), /// Connect to node with the given address. Connect(NodeId, Address, ConnectOptions), /// Disconnect from node. Disconnect(NodeId), /// Get the node configuration. - Config(chan::Sender), + Config(Sender), /// Get the node's listen addresses. - ListenAddrs(chan::Sender>), + ListenAddrs(Sender>), /// Lookup seeds for the given repository in the routing table, and report /// sync status for given namespaces. - Seeds(RepoId, HashSet, chan::Sender), + Seeds(RepoId, HashSet, Sender), /// Fetch the given repository from the network. - Fetch(RepoId, NodeId, time::Duration, chan::Sender), + Fetch(RepoId, NodeId, time::Duration, Sender), /// Seed the given repository. - Seed(RepoId, Scope, chan::Sender), + Seed(RepoId, Scope, Sender), /// Unseed the given repository. - Unseed(RepoId, chan::Sender), + Unseed(RepoId, Sender), /// Follow the given node. - Follow(NodeId, Option, chan::Sender), + Follow(NodeId, Option, Sender), /// Unfollow the given node. - Unfollow(NodeId, chan::Sender), + Unfollow(NodeId, Sender), /// Query the internal service state. - QueryState(Arc, chan::Sender>), + QueryState(Arc, Sender>), } impl fmt::Debug for Command {