forked/hyper
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

style(common): remove FutureExt::boxed to unify project style

Browse Source
This commit is contained in:
Atkins
2019-09-03 20:38:43 +08:00
committed by Sean McArthur
parent 347a10eb05
commit 69c15cae5c
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/common/drain.rs
View File

@@ -1,9 +1,9 @@
use std::mem; use std::mem;
use futures_util::FutureExt as _;
use tokio_sync::{mpsc, watch}; use tokio_sync::{mpsc, watch};
use super::{Future, Never, Poll, Pin, task}; use super::{Future, Never, Poll, Pin, task};
use futures_util::FutureExt as _;
// Sentinel value signaling that the watch is still open // Sentinel value signaling that the watch is still open
enum Action { enum Action {
@@ -100,9 +100,10 @@ where
loop { loop {
match mem::replace(&mut me.state, State::Draining) { match mem::replace(&mut me.state, State::Draining) {
State::Watch(on_drain) => { State::Watch(on_drain) => {
let mut recv_fut = me.watch.rx.recv_ref().boxed(); let recv = me.watch.rx.recv_ref();
futures_util::pin_mut!(recv);
match recv_fut.poll_unpin(cx) { match recv.poll_unpin(cx) {
Poll::Ready(None) => { Poll::Ready(None) => {
// Drain has been triggered! // Drain has been triggered!
on_drain(unsafe { Pin::new_unchecked(&mut me.future) }); on_drain(unsafe { Pin::new_unchecked(&mut me.future) });