Function writeRedisInteger

internal/api/redis_queue_protocol.go:543–549

(writer *bufio.Writer, value int)

}

func writeRedisInteger(writer *bufio.Writer, value int) error {
	if writer == nil {
		return net.ErrClosed
	}
	_, errWrite := writer.WriteString(":" + strconv.Itoa(value) + "\r\n")
	return errWrite
}

func writeRedisArrayHeader(writer *bufio.Writer, count int) error {
	if writer == nil {