mirror of
https://github.com/tokio-rs/tokio.git
synced 2026-09-08 00:00:13 +02:00
wip
This commit is contained in:
@@ -412,8 +412,8 @@ async fn multi_gated() {
|
|||||||
}
|
}
|
||||||
|
|
||||||
poll_fn(move |cx| {
|
poll_fn(move |cx| {
|
||||||
|
gate.waker.register_by_ref(cx.waker());
|
||||||
if gate.count.load(SeqCst) < 2 {
|
if gate.count.load(SeqCst) < 2 {
|
||||||
gate.waker.register_by_ref(cx.waker());
|
|
||||||
Poll::Pending
|
Poll::Pending
|
||||||
} else {
|
} else {
|
||||||
Poll::Ready(())
|
Poll::Ready(())
|
||||||
|
|||||||
Reference in New Issue
Block a user