Chore: fmt

databendlabs · Feb 29, 2024 · 0c7b33e · 0c7b33e
1 parent c84b76c
commit 0c7b33e
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 4 deletions.
diff --git 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<T: OptionalSend>(pub tokio::sync::oneshot::Sender<T>);
-
 impl AsyncRuntime for TokioRuntime {
     type JoinError = tokio::task::JoinError;
     type JoinHandle<T: OptionalSend + 'static> = tokio::task::JoinHandle<T>;

diff --git 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<T, E>(&self, tx: ResultSender<C, T, E>)
-    where 
+    where
         T: OptionalSend + Debug,
         E: OptionalSend + Debug,
-        E: From<ForwardToLeader<C::NodeId, C::Node>>
+        E: From<ForwardToLeader<C::NodeId, C::Node>>,
     {
         let mut leader_id = self.current_leader();
         let leader_node = self.get_leader_node(leader_id);