(args ...string)
| 333 | } |
| 334 | |
| 335 | func encodeRESPArray(args ...string) []byte { |
| 336 | var buf bytes.Buffer |
| 337 | buf.WriteString("*") |
| 338 | buf.WriteString(strconv.Itoa(len(args))) |
| 339 | buf.WriteString("\r\n") |
| 340 | for _, arg := range args { |
| 341 | buf.WriteString("$") |
| 342 | buf.WriteString(strconv.Itoa(len(arg))) |
| 343 | buf.WriteString("\r\n") |
| 344 | buf.WriteString(arg) |
| 345 | buf.WriteString("\r\n") |
| 346 | } |
| 347 | return buf.Bytes() |
| 348 | } |
| 349 | |
| 350 | func readRESPBulk(reader *bufio.Reader) ([]byte, error) { |
| 351 | prefix, errRead := reader.ReadByte() |
no test coverage detected