public-collect/books-futures-explained
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

make code compile, and fix typo

Browse Source
This commit is contained in:
WindSoilder
2020-05-06 09:10:56 +08:00
parent 786faf4fd9
commit 41b28f466f
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/6_future_example.md
View File

@@ -72,7 +72,7 @@ fn block_on<F: Future>(mut future: F) -> F::Output {
// an event occurs, or a thread has a "spurious wakeup" (an unexpected wakeup // an event occurs, or a thread has a "spurious wakeup" (an unexpected wakeup
// that can happen for no good reason). // that can happen for no good reason).
let val = loop { let val = loop {
match Future::poll(future, &mut cx) { match Future::poll(future.as_mut(), &mut cx) {
// when the Future is ready we're finished // when the Future is ready we're finished
Poll::Ready(val) => break val, Poll::Ready(val) => break val,
@@ -431,7 +431,7 @@ impl Reactor {
impl Drop for Reactor { impl Drop for Reactor {
fn drop(&mut self) { fn drop(&mut self) {
// We send a close event to the reactor so it closes down our reactor-thread. // We send a close event to the reactor so it closes down our reactor-thread.
// If we don't do that we'll en up waiting forever for new events. // If we don't do that we'll end up waiting forever for new events.
self.dispatcher.send(Event::Close).unwrap(); self.dispatcher.send(Event::Close).unwrap();
self.handle.take().map(|h| h.join().unwrap()).unwrap(); self.handle.take().map(|h| h.join().unwrap()).unwrap();
} }