We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 86ff562 commit 081e5b3Copy full SHA for 081e5b3
internal/proto/elastic_reader.go
@@ -40,13 +40,6 @@ func (b *ElasticBufReader) ResetBuffer(buf []byte) {
40
b.err = nil
41
}
42
43
-func (b *ElasticBufReader) reset(buf []byte, rd io.Reader) {
44
- *b = ElasticBufReader{
45
- buf: buf,
46
- rd: rd,
47
- }
48
-}
49
-
50
// Buffered returns the number of bytes that can be read from the current buffer.
51
func (b *ElasticBufReader) Buffered() int {
52
return b.w - b.r
internal/proto/reader.go
@@ -8,8 +8,6 @@ import (
8
"github.com/go-redis/redis/internal/util"
9
)
10
11
-const bytesAllocLimit = 1024 * 1024 // 1mb
12
13
const (
14
ErrorReply = '-'
15
StatusReply = '+'
0 commit comments