Skip to content

Commit

Permalink
fix example
Browse files Browse the repository at this point in the history
Signed-off-by: Yury-Fridlyand <[email protected]>
  • Loading branch information
Yury-Fridlyand committed Jan 14, 2025
1 parent 5c9b9be commit 5414fe9
Showing 1 changed file with 27 additions and 27 deletions.
54 changes: 27 additions & 27 deletions go/api/base_client.go
Original file line number Diff line number Diff line change
Expand Up @@ -1352,19 +1352,19 @@ func (client *baseClient) XAddWithOptions(
//
// For example:
//
// result, err := client.XReadGroup({"stream1": "0-0", "stream2": "0-1", "stream3": "0-1"})
// err == nil: true
// result: map[string]map[string][][]string{
// "stream1": {
// "0-1": {{"field1", "value1"}},
// "0-2": {{"field2", "value2"}, {"field2", "value3"}},
// },
// "stream2": {
// "1526985676425-0": {{"name", "Virginia"}, {"surname", "Woolf"}},
// "1526985685298-0": nil, // entry was deleted
// }
// "stream3": {}, // stream is empty
// }
// result, err := client.XReadGroup({"stream1": "0-0", "stream2": "0-1", "stream3": "0-1"})
// err == nil: true
// result: map[string]map[string][][]string{
// "stream1": {
// "0-1": {{"field1", "value1"}},
// "0-2": {{"field2", "value2"}, {"field2", "value3"}},
// },
// "stream2": {
// "1526985676425-0": {{"name", "Virginia"}, {"surname", "Woolf"}},
// "1526985685298-0": nil, // entry was deleted
// },
// "stream3": {}, // stream is empty
// }
//
// [valkey.io]: https://valkey.io/commands/xreadgroup/
func (client *baseClient) XReadGroup(
Expand Down Expand Up @@ -1396,20 +1396,20 @@ func (client *baseClient) XReadGroup(
//
// For example:
//
// options := options.NewXReadGroupOptions().SetNoAck()
// result, err := client.XReadGroupWithOptions({"stream1": "0-0", "stream2": "0-1", "stream3": "0-1"}, options)
// err == nil: true
// result: map[string]map[string][][]string{
// "stream1": {
// "0-1": {{"field1", "value1"}},
// "0-2": {{"field2", "value2"}, {"field2", "value3"}},
// },
// "stream2": {
// "1526985676425-0": {{"name", "Virginia"}, {"surname", "Woolf"}},
// "1526985685298-0": nil, // entry was deleted
// }
// "stream3": {}, // stream is empty
// }
// options := options.NewXReadGroupOptions().SetNoAck()
// result, err := client.XReadGroupWithOptions({"stream1": "0-0", "stream2": "0-1", "stream3": "0-1"}, options)
// err == nil: true
// result: map[string]map[string][][]string{
// "stream1": {
// "0-1": {{"field1", "value1"}},
// "0-2": {{"field2", "value2"}, {"field2", "value3"}},
// },
// "stream2": {
// "1526985676425-0": {{"name", "Virginia"}, {"surname", "Woolf"}},
// "1526985685298-0": nil, // entry was deleted
// },
// "stream3": {}, // stream is empty
// }
//
// [valkey.io]: https://valkey.io/commands/xreadgroup/
func (client *baseClient) XReadGroupWithOptions(
Expand Down

0 comments on commit 5414fe9

Please sign in to comment.