Use broadcast::Receiver::recv instead of next

On newer versions of Tokio the `Receiver` doesn't implement `Stream`.
ZcashFoundation · Oct 21, 2021 · 9da067d · 9da067d
1 parent 86d05c5
commit 9da067d
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/tower-batch/src/worker.rs b/tower-batch/src/worker.rs
@@ -6,7 +6,6 @@ use std::{
 use futures::future::TryFutureExt;
 use pin_project::pin_project;
 use tokio::{
-    stream::StreamExt,
     sync::mpsc,
     time::{sleep, Sleep},
 };
@@ -127,7 +126,7 @@ where
         let mut pending_items = 0usize;
         loop {
             match timer {
-                None => match self.rx.next().await {
+                None => match self.rx.recv().await {
                     // The first message in a new batch.
                     Some(msg) => {
                         let span = msg.span;