Read wraps the underlying ReadWriteCloser's Read method and keeps the session alive with the "input" traffic type.
(p []byte)
| 421 | |
| 422 | // Read wraps the underlying ReadWriteCloser's Read method and keeps the session alive with the "input" traffic type. |
| 423 | func (t *trafficMonitor) Read(p []byte) (n int, err error) { |
| 424 | t.fwd.KeepAlive(trafficTypeInput) |
| 425 | return t.rwc.Read(p) |
| 426 | } |
| 427 | |
| 428 | // Write wraps the underlying ReadWriteCloser's Write method and keeps the session alive with the "output" traffic type. |
| 429 | func (t *trafficMonitor) Write(p []byte) (n int, err error) { |