From d35f81ae2d9818bc279ae2f2eb8fdf9738391f4d Mon Sep 17 00:00:00 2001 From: Ruslan Tushov Date: Wed, 17 Jan 2024 16:00:24 +0300 Subject: [PATCH] propagate one --- .../propagate_transactions_protocol.cpp | 16 +++++++--------- 1 file changed, 7 insertions(+), 9 deletions(-) diff --git a/core/network/impl/protocols/propagate_transactions_protocol.cpp b/core/network/impl/protocols/propagate_transactions_protocol.cpp index c0eb4310a7..dc152f6bc7 100644 --- a/core/network/impl/protocols/propagate_transactions_protocol.cpp +++ b/core/network/impl/protocols/propagate_transactions_protocol.cpp @@ -162,15 +162,13 @@ namespace kagome::network { } } - auto propagated_exts = KAGOME_EXTRACT_SHARED_CACHE( - PropagateTransactionsProtocol, PropagatedExtrinsics); - propagated_exts->extrinsics.resize(txs.size()); - std::transform(txs.begin(), - txs.end(), - propagated_exts->extrinsics.begin(), - [](auto &tx) { return tx.ext; }); - stream_engine_->broadcast(shared_from_this(), - propagated_exts); + for (auto &tx : txs) { + auto propagated_exts = KAGOME_EXTRACT_SHARED_CACHE( + PropagateTransactionsProtocol, PropagatedExtrinsics); + propagated_exts->extrinsics = {tx.ext}; + stream_engine_->broadcast(shared_from_this(), + propagated_exts); + } } } // namespace kagome::network