From 07b98751c3273000fcc5e5dc1f0c93b6af3edc15 Mon Sep 17 00:00:00 2001 From: Vladimir Mihailenco Date: Tue, 19 Feb 2019 16:29:47 +0200 Subject: [PATCH] Add Streams comment --- commands.go | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/commands.go b/commands.go index 6433595..653e4ab 100644 --- a/commands.go +++ b/commands.go @@ -1453,10 +1453,11 @@ func (c *cmdable) XGroupDelConsumer(stream, group, consumer string) *IntCmd { type XReadGroupArgs struct { Group string Consumer string - Streams []string - Count int64 - Block time.Duration - NoAck bool + // List of streams and ids. + Streams []string + Count int64 + Block time.Duration + NoAck bool } func (c *cmdable) XReadGroup(a *XReadGroupArgs) *XStreamSliceCmd {