Skip to content

Commit 3f6e5a8

Browse files
committed
return errors when they occur
1 parent d3b325c commit 3f6e5a8

File tree

1 file changed

+3
-5
lines changed

1 file changed

+3
-5
lines changed

search_commands.go

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -681,12 +681,10 @@ func (cmd *AggregateCmd) String() string {
681681
func (cmd *AggregateCmd) readReply(rd *proto.Reader) (err error) {
682682
data, err := rd.ReadSlice()
683683
if err != nil {
684-
cmd.err = err
685684
return err
686685
}
687686
cmd.val, err = ProcessAggregateResult(data)
688687
if err != nil {
689-
cmd.err = err
690688
return err
691689
}
692690
return nil
@@ -1428,7 +1426,7 @@ func (cmd *FTInfoCmd) readReply(rd *proto.Reader) (err error) {
14281426
}
14291427
cmd.val, err = parseFTInfo(data)
14301428
if err != nil {
1431-
cmd.err = err
1429+
return err
14321430
}
14331431

14341432
return nil
@@ -1525,7 +1523,7 @@ func (cmd *FTSpellCheckCmd) readReply(rd *proto.Reader) (err error) {
15251523
}
15261524
cmd.val, err = parseFTSpellCheck(data)
15271525
if err != nil {
1528-
cmd.err = err
1526+
return err
15291527
}
15301528
return nil
15311529
}
@@ -1713,7 +1711,7 @@ func (cmd *FTSearchCmd) readReply(rd *proto.Reader) (err error) {
17131711
}
17141712
cmd.val, err = parseFTSearch(data, cmd.options.NoContent, cmd.options.WithScores, cmd.options.WithPayloads, cmd.options.WithSortKeys)
17151713
if err != nil {
1716-
cmd.err = err
1714+
return err
17171715
}
17181716
return nil
17191717
}

0 commit comments

Comments
 (0)