diff --git a/crates/relay-raft/src/lib.rs b/crates/relay-raft/src/lib.rs index e47ff73..a6c7b3e 100644 --- a/crates/relay-raft/src/lib.rs +++ b/crates/relay-raft/src/lib.rs @@ -52,6 +52,7 @@ impl RaftConnection { let Ok(messages) = self.node.append(data) else { panic!("OOOOOOOOH!"); }; + Self::send_raft_messages(&self.connection, &self.peers, messages); } else { data.push(1); if let (Some(leader), _) = self.node.leader() {