@@ -1054,12 +1054,10 @@ func (m *RedisMessage) AsXRangeSlice() (XRangeSlice, error) {
1054
1054
if len (values ) != 2 {
1055
1055
return XRangeSlice {}, fmt .Errorf ("got %d, wanted 2" , len (values ))
1056
1056
}
1057
-
1058
1057
id , err := values [0 ].ToString ()
1059
1058
if err != nil {
1060
1059
return XRangeSlice {}, err
1061
1060
}
1062
-
1063
1061
// Handle the field-values array
1064
1062
fieldArray , err := values [1 ].ToArray ()
1065
1063
if err != nil {
@@ -1068,7 +1066,6 @@ func (m *RedisMessage) AsXRangeSlice() (XRangeSlice, error) {
1068
1066
}
1069
1067
return XRangeSlice {}, err
1070
1068
}
1071
-
1072
1069
// Convert pairs to slice (preserving order)
1073
1070
fieldValues := make ([]XRangeFieldValue , 0 , len (fieldArray )/ 2 )
1074
1071
for i := 0 ; i < cap (fieldValues ); i ++ {
@@ -1079,7 +1076,6 @@ func (m *RedisMessage) AsXRangeSlice() (XRangeSlice, error) {
1079
1076
Value : value ,
1080
1077
})
1081
1078
}
1082
-
1083
1079
return XRangeSlice {
1084
1080
ID : id ,
1085
1081
FieldValues : fieldValues ,
@@ -1092,7 +1088,6 @@ func (m *RedisMessage) AsXRangeSlices() ([]XRangeSlice, error) {
1092
1088
if err != nil {
1093
1089
return nil , err
1094
1090
}
1095
-
1096
1091
msgs := make ([]XRangeSlice , 0 , len (values ))
1097
1092
for _ , v := range values {
1098
1093
msg , err := v .AsXRangeSlice ()
@@ -1109,10 +1104,8 @@ func (m *RedisMessage) AsXReadSlices() (map[string][]XRangeSlice, error) {
1109
1104
if err := m .Error (); err != nil {
1110
1105
return nil , err
1111
1106
}
1112
-
1113
1107
var ret map [string ][]XRangeSlice
1114
1108
var err error
1115
-
1116
1109
if m .IsMap () {
1117
1110
ret = make (map [string ][]XRangeSlice , len (m .values ())/ 2 )
1118
1111
for i := 0 ; i < len (m .values ()); i += 2 {
@@ -1122,7 +1115,6 @@ func (m *RedisMessage) AsXReadSlices() (map[string][]XRangeSlice, error) {
1122
1115
}
1123
1116
return ret , nil
1124
1117
}
1125
-
1126
1118
if m .IsArray () {
1127
1119
ret = make (map [string ][]XRangeSlice , len (m .values ()))
1128
1120
for _ , v := range m .values () {
@@ -1135,7 +1127,6 @@ func (m *RedisMessage) AsXReadSlices() (map[string][]XRangeSlice, error) {
1135
1127
}
1136
1128
return ret , nil
1137
1129
}
1138
-
1139
1130
typ := m .typ
1140
1131
return nil , fmt .Errorf ("%w: valkey message type %s is not a map/array/set" , errParse , typeNames [typ ])
1141
1132
}
0 commit comments