in src/session/stream.rs [135:144]
fn read(&mut self, buf: &mut [u8]) -> Result<usize, Error> {
if let Some(stream) = &mut self.inner {
stream.read(buf)
} else {
Err(Error::new(
ErrorKind::NotConnected,
"session is not connected",
))
}
}