actix/actix-net
1
0
Fork 0
mirror of https://github.com/fafhrd91/actix-net synced 2025-02-17 13:33:31 +01:00
Code Issues Releases Wiki Activity

local-channel: drop futures-util by using future::poll_fn from std (#490)

Browse Source
This commit is contained in:
Paolo Barbolini 2023-09-17 13:45:55 +02:00 committed by GitHub
parent 14272a1762
commit bfeb4cd9e7
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
local-channel/Cargo.toml
View File

@ -15,8 +15,8 @@ rust-version.workspace = true
[dependencies] [dependencies]
futures-core = "0.3.17" futures-core = "0.3.17"
futures-sink = "0.3.17" futures-sink = "0.3.17"
futures-util = { version = "0.3.17", default-features = false }
local-waker = "0.1" local-waker = "0.1"
[dev-dependencies] [dev-dependencies]
futures-util = { version = "0.3.17", default-features = false }
tokio = { version = "1.23.1", features = ["rt", "macros"] } tokio = { version = "1.23.1", features = ["rt", "macros"] }

2
local-channel/src/mpsc.rs
View File

@ -4,6 +4,7 @@ use alloc::{collections::VecDeque, rc::Rc};
use core::{ use core::{
cell::RefCell, cell::RefCell,
fmt, fmt,
future::poll_fn,
pin::Pin, pin::Pin,
task::{Context, Poll}, task::{Context, Poll},
}; };
@ -11,7 +12,6 @@ use std::error::Error;
use futures_core::stream::Stream; use futures_core::stream::Stream;
use futures_sink::Sink; use futures_sink::Sink;
use futures_util::future::poll_fn;
use local_waker::LocalWaker; use local_waker::LocalWaker;
/// Creates a unbounded in-memory channel with buffered storage. /// Creates a unbounded in-memory channel with buffered storage.