pezkuwichain/pezkuwi-telemetry
1
0
Fork 0
mirror of https://github.com/pezkuwichain/pezkuwi-telemetry.git synced 2026-06-18 05:01:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

remove final use of futures::mpsc and replace with flume

Browse Source
This commit is contained in:
James Wilson
2021-08-10 10:35:11 +01:00
parent 703a9ddc4e
commit 11b0b3a3c7
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
backend/telemetry_core/src/aggregator/aggregator_set.rs
+4 -1
View File
@@ -52,8 +52,11 @@ impl AggregatorSet {
.map(|a| a.subscribe_shard()) .map(|a| a.subscribe_shard())
.collect(); .collect();
let (tx, rx) = flume::unbounded::<FromShardWebsocket>();
let mut rx = rx.into_stream();
let tx = tx.into_sink();
// Send every incoming message to all aggregators. // Send every incoming message to all aggregators.
let (tx, mut rx) = futures::channel::mpsc::unbounded::<FromShardWebsocket>();
tokio::spawn(async move { tokio::spawn(async move {
while let Some(msg) = rx.next().await { while let Some(msg) = rx.next().await {
for conn in &mut conns { for conn in &mut conns {