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