(conn *Conn, bufsize int)
| 84 | } |
| 85 | |
| 86 | func newConnDecoder(conn *Conn, bufsize int) *Decoder { |
| 87 | r := &connReader{Conn: conn} |
| 88 | r.Slice = unsafe2.MakeSlice(bufsize) |
| 89 | return NewDecoderBuffer(bufio2.NewReaderBuffer(r, r.Buffer())) |
| 90 | } |
| 91 | |
| 92 | func (r *connReader) Read(b []byte) (int, error) { |
| 93 | if timeout := r.ReaderTimeout; timeout != 0 { |
no test coverage detected