diff --git a/local-channel/Cargo.toml b/local-channel/Cargo.toml index 9e0f21b4b7..fcc7ae965b 100644 --- a/local-channel/Cargo.toml +++ b/local-channel/Cargo.toml @@ -15,8 +15,8 @@ rust-version.workspace = true [dependencies] futures-core = "0.3.17" futures-sink = "0.3.17" -futures-util = { version = "0.3.17", default-features = false } local-waker = "0.1" [dev-dependencies] +futures-util = { version = "0.3.17", default-features = false } tokio = { version = "1.23.1", features = ["rt", "macros"] } diff --git a/local-channel/src/mpsc.rs b/local-channel/src/mpsc.rs index c75d03bbe2..7fec561126 100644 --- a/local-channel/src/mpsc.rs +++ b/local-channel/src/mpsc.rs @@ -4,6 +4,7 @@ use alloc::{collections::VecDeque, rc::Rc}; use core::{ cell::RefCell, fmt, + future::poll_fn, pin::Pin, task::{Context, Poll}, }; @@ -11,7 +12,6 @@ use std::error::Error; use futures_core::stream::Stream; use futures_sink::Sink; -use futures_util::future::poll_fn; use local_waker::LocalWaker; /// Creates a unbounded in-memory channel with buffered storage.