(stream io.ReadWriter, logger *zerolog.Logger, max uint64)
| 17 | } |
| 18 | |
| 19 | func NewDebugStream(stream io.ReadWriter, logger *zerolog.Logger, max uint64) *DebugStream { |
| 20 | return &DebugStream{ |
| 21 | reader: stream, |
| 22 | writer: stream, |
| 23 | log: logger, |
| 24 | max: max, |
| 25 | } |
| 26 | } |
| 27 | |
| 28 | func (d *DebugStream) Read(p []byte) (n int, err error) { |
| 29 | n, err = d.reader.Read(p) |