(conn *Conn, bufsize int)
| 116 | } |
| 117 | |
| 118 | func newConnEncoder(conn *Conn, bufsize int) *Encoder { |
| 119 | w := &connWriter{Conn: conn} |
| 120 | w.Slice = unsafe2.MakeSlice(bufsize) |
| 121 | return NewEncoderBuffer(bufio2.NewWriterBuffer(w, w.Buffer())) |
| 122 | } |
| 123 | |
| 124 | func (w *connWriter) Write(b []byte) (int, error) { |
| 125 | if timeout := w.WriterTimeout; timeout != 0 { |
no test coverage detected