diff --git a/crates/mempool_p2p/src/runner/mod.rs b/crates/mempool_p2p/src/runner/mod.rs index eaf3cca2cf..12c58a58c2 100644 --- a/crates/mempool_p2p/src/runner/mod.rs +++ b/crates/mempool_p2p/src/runner/mod.rs @@ -56,11 +56,10 @@ impl ComponentStarter for MempoolP2pRunner { Some((message_result, broadcasted_message_metadata)) = self.broadcasted_topic_server.next() => { match message_result { Ok(message) => { - // TODO(eitan): Add message metadata. // TODO(eitan): make this call non blocking by adding this future to a // FuturesUnordered that will be polled in the select. match self.gateway_client.add_tx( - GatewayInput { rpc_tx: message.0, message_metadata: None } + GatewayInput { rpc_tx: message.0, message_metadata: Some(broadcasted_message_metadata.clone()) } ).await { Ok(_tx_hash) => {} Err(e) => {