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