in src/session/stream.rs [198:212]
fn register(
&mut self,
registry: &mio::Registry,
token: mio::Token,
interest: mio::Interest,
) -> std::result::Result<(), std::io::Error> {
if let Some(stream) = &mut self.inner {
stream.register(registry, token, interest)
} else {
Err(Error::new(
ErrorKind::NotConnected,
"session is not connected",
))
}
}