Step 3 – Implementing a proper Reactor
The final part of our example is the Reactor. Our Reactor will:
- Efficiently wait and handle events that our runtime is interested in
- Store a collection of
Wakertypes and make sure to wake the correctWakerwhen it gets a notification on a source it’s tracking - Provide the necessary mechanisms for leaf futures such as
HttpGetFuture, to register and deregister interests in events - Provide a way for leaf futures to store the last received
Waker
When we’re done with this step, we should have everything we need for our runtime, so let’s get to it.
Start by opening the reactor.rs file.
The first thing we do is add the dependencies we need:
ch08/b-reactor-executor/src/runtime/reactor.rs
use crate::runtime::Waker;
use mio::{net::TcpStream, Events, Interest, Poll, Registry, Token};
use std::{
collections::HashMap,
sync::{
...