rebase

shotover · Aug 15, 2022 · 851b386 · 851b386
1 parent 4859944
commit 851b386
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/shotover-proxy/src/transforms/cassandra/sink_cluster.rs b/shotover-proxy/src/transforms/cassandra/sink_cluster.rs
@@ -215,7 +215,7 @@ impl CassandraSinkCluster {
  if let Some(outbound) = &node.outbound {
  let (return_chan_tx, return_chan_rx) = oneshot::channel();
  outbound.send(message.clone(), return_chan_tx)?;
- responses_future_use.push(return_chan_rx);
+ responses_future_use.push_back(return_chan_rx);
  use_future_index_to_node_index.push(node_index);
  }
  }