Skip to content

Commit

Permalink
Add Streams comment
Browse files Browse the repository at this point in the history
  • Loading branch information
vmihailenco committed Feb 19, 2019
1 parent 6887714 commit 07b9875
Showing 1 changed file with 5 additions and 4 deletions.
9 changes: 5 additions & 4 deletions commands.go
Original file line number Diff line number Diff line change
Expand Up @@ -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 {
Expand Down

0 comments on commit 07b9875

Please sign in to comment.