(n int)
| 123 | } |
| 124 | |
| 125 | func newBenchmarkDecoder(n int) *Decoder { |
| 126 | r := NewArray([]*Resp{ |
| 127 | NewBulkBytes(make([]byte, n)), |
| 128 | }) |
| 129 | p, err := EncodeToBytes(r) |
| 130 | assert.MustNoError(err) |
| 131 | var b bytes.Buffer |
| 132 | for i := 0; i < 128 && b.Len() < 1024*1024; i++ { |
| 133 | _, err := b.Write(p) |
| 134 | assert.MustNoError(err) |
| 135 | } |
| 136 | return NewDecoderSize(&loopReader{buf: b.Bytes()}, 1024*128) |
| 137 | } |
| 138 | |
| 139 | func benchmarkDecode(b *testing.B, n int) { |
| 140 | d := newBenchmarkDecoder(n) |
no test coverage detected