in src/session/tcp_stream.rs [53:62]
fn write(&mut self, buf: &[u8]) -> std::result::Result<usize, std::io::Error> {
let result = self.inner.write(buf);
if let Ok(bytes) = result {
if bytes != buf.len() {
// TCP_SEND_PARTIAL.increment();
}
// TCP_SEND_BYTE.add(bytes as _);
}
result
}