Read wraps the underlying ReadWriteCloser's Read method and keeps the session alive with the "input" traffic type.
(p []byte)
| 443 | |
| 444 | // Read wraps the underlying ReadWriteCloser's Read method and keeps the session alive with the "input" traffic type. |
| 445 | func (t *trafficMonitor) Read(p []byte) (n int, err error) { |
| 446 | t.fwd.KeepAlive(trafficTypeInput) |
| 447 | return t.rwc.Read(p) |
| 448 | } |
| 449 | |
| 450 | // Write wraps the underlying ReadWriteCloser's Write method and keeps the session alive with the "output" traffic type. |
| 451 | func (t *trafficMonitor) Write(p []byte) (n int, err error) { |