diff --git a/connection.go b/connection.go index 1d99664a..774e55f1 100644 --- a/connection.go +++ b/connection.go @@ -720,7 +720,7 @@ func (c *connection) mainReadLoop() error { cl := t.cl decoder := pp.Decoder{ - R: bufio.NewReader(c.r), + R: bufio.NewReaderSize(c.r, 1<<17), MaxLength: 256 * 1024, Pool: t.chunkPool, }