From 0c7b33e76b7579ee5c68efc891ba904e0a28a8cd Mon Sep 17 00:00:00 2001 From: Anthony Griffon Date: Thu, 29 Feb 2024 16:27:30 +0100 Subject: [PATCH] Chore: fmt --- openraft/src/async_runtime.rs | 2 -- openraft/src/core/raft_core.rs | 4 ++-- 2 files changed, 2 insertions(+), 4 deletions(-) diff --git a/openraft/src/async_runtime.rs b/openraft/src/async_runtime.rs index b6aa95aca..ebfb2bdc9 100644 --- a/openraft/src/async_runtime.rs +++ b/openraft/src/async_runtime.rs @@ -100,8 +100,6 @@ pub trait AsyncRuntime: Debug + Default + PartialEq + Eq + OptionalSend + Option #[derive(Debug, Default, PartialEq, Eq)] pub struct TokioRuntime; -// pub struct TokioOneShotSender(pub tokio::sync::oneshot::Sender); - impl AsyncRuntime for TokioRuntime { type JoinError = tokio::task::JoinError; type JoinHandle = tokio::task::JoinHandle; diff --git a/openraft/src/core/raft_core.rs b/openraft/src/core/raft_core.rs index 0672920a4..54ddf09da 100644 --- a/openraft/src/core/raft_core.rs +++ b/openraft/src/core/raft_core.rs @@ -623,10 +623,10 @@ where /// Reject a request due to the Raft node being in a state which prohibits the request. #[tracing::instrument(level = "trace", skip(self, tx))] pub(crate) fn reject_with_forward_to_leader(&self, tx: ResultSender) - where + where T: OptionalSend + Debug, E: OptionalSend + Debug, - E: From> + E: From>, { let mut leader_id = self.current_leader(); let leader_node = self.get_leader_node(leader_id);