From fd5c84bb4fa2f23b17e791122d47f3759ae1469b Mon Sep 17 00:00:00 2001 From: Guy Nir Date: Sun, 17 Nov 2024 15:22:44 +0200 Subject: [PATCH] feat: allow a streamed proposal channel on top of existing one --- .../src/sequencer_consensus_context_test.rs | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/crates/sequencing/papyrus_consensus_orchestrator/src/sequencer_consensus_context_test.rs b/crates/sequencing/papyrus_consensus_orchestrator/src/sequencer_consensus_context_test.rs index 1b2ef6c171..85f034e3ac 100644 --- a/crates/sequencing/papyrus_consensus_orchestrator/src/sequencer_consensus_context_test.rs +++ b/crates/sequencing/papyrus_consensus_orchestrator/src/sequencer_consensus_context_test.rs @@ -160,7 +160,11 @@ async fn validate_proposal_success() { broadcasted_messages_receiver: inbound_network_receiver, broadcast_topic_client: outbound_network_sender, } = subscriber_channels; +<<<<<<< HEAD let (outbound_internal_sender, _inbound_internal_receiver, _) = +======= + let (outbound_internal_sender, _inbound_internal_receiver) = +>>>>>>> 883a253be (feat: allow a streamed proposal channel on top of existing one) StreamHandler::get_channels(inbound_network_receiver, outbound_network_sender); let mut context = SequencerConsensusContext::new( @@ -213,7 +217,11 @@ async fn repropose() { broadcasted_messages_receiver: inbound_network_receiver, broadcast_topic_client: outbound_network_sender, } = subscriber_channels; +<<<<<<< HEAD let (outbound_internal_sender, _inbound_internal_receiver, _) = +======= + let (outbound_internal_sender, _inbound_internal_receiver) = +>>>>>>> 883a253be (feat: allow a streamed proposal channel on top of existing one) StreamHandler::get_channels(inbound_network_receiver, outbound_network_sender); let mut context = SequencerConsensusContext::new(