Use cx.local_waker().wake()

MajorBreakfast · cramertj · commit 3df88d6c45c2 · 2018-06-22T16:32:02.000-07:00
diff --git a/futures-util/src/stream/futures_unordered/mod.rs b/futures-util/src/stream/futures_unordered/mod.rs
@@ -249,7 +249,7 @@ impl<T> Stream for FuturesUnordered<T>
                     // At this point, it may be worth yielding the thread &
                     // spinning a few times... but for now, just yield using the
                     // task system.
-                    cx.waker().wake();
+                    cx.local_waker().wake();
                     return Poll::Pending;
                 }
                 Dequeue::Data(node) => node,

Original file line number	Diff line number	Diff line change
`@@ -249,7 +249,7 @@ impl<T> Stream for FuturesUnordered<T>`
`249`	`249`	`// At this point, it may be worth yielding the thread &`
`250`	`250`	`// spinning a few times... but for now, just yield using the`
`251`	`251`	`// task system.`
`252`		`- cx.waker().wake();`
	`252`	`+ cx.local_waker().wake();`
`253`	`253`	`return Poll::Pending;`
`254`	`254`	`}`
`255`	`255`	`Dequeue::Data(node) => node,`