refactor: converts deprecated FuturesUnordered::push to FuturesUnorde…

…red::push_back
MystenLabs · Aug 16, 2022 · cff7a37 · cff7a37
1 parent 6f64988
commit cff7a37
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/crates/sui-core/src/authority_active/gossip/mod.rs b/crates/sui-core/src/authority_active/gossip/mod.rs
@@ -533,7 +533,7 @@ where
                             last_seq_in_cur_batch = seq;
 
                             let fut = handler.handle_digest(self, digests).await?;
-                            results.push(async move {
+                            results.push_back(async move {
                                 fut.await?;
                                 Ok::<(TxSequenceNumber, ExecutionDigests), SuiError>((seq, digests))
                             });

diff --git a/crates/sui-core/src/node_sync/node_follower.rs b/crates/sui-core/src/node_sync/node_follower.rs
@@ -705,7 +705,7 @@ impl NodeSyncHandle {
             let (tx, rx) = oneshot::channel();
             let msg = DigestsMessage::new_for_ckpt(digests, tx);
             Self::send_msg_with_tx(self.sender.clone(), msg).await?;
-            futures.push(Self::map_rx(rx));
+            futures.push_back(Self::map_rx(rx));
         }
 
         Ok(futures)
@@ -720,7 +720,7 @@ impl NodeSyncHandle {
             let (tx, rx) = oneshot::channel();
             let msg = DigestsMessage::new_for_exec_driver(&digest, tx);
             Self::send_msg_with_tx(self.sender.clone(), msg).await?;
-            futures.push(Self::map_rx(rx));
+            futures.push_back(Self::map_rx(rx));
         }
 
         Ok(futures)