Add hint on Streams usage

vmihailenco · vmihailenco · commit 08dad1eb7f5b · 2020-01-12T12:14:22.000+02:00
diff --git a/commands.go b/commands.go
@@ -1405,7 +1405,7 @@ func (c cmdable) XRevRangeN(stream, start, stop string, count int64) *XMessageSl
 }
 
 type XReadArgs struct {
-	Streams []string
+	Streams []string // list of streams and ids, e.g. stream1 stream2 id1 id2
 	Count   int64
 	Block   time.Duration
 }
@@ -1421,6 +1421,7 @@ func (c cmdable) XRead(a *XReadArgs) *XStreamSliceCmd {
 		args = append(args, "block")
 		args = append(args, int64(a.Block/time.Millisecond))
 	}
+
 	args = append(args, "streams")
 	for _, s := range a.Streams {
 		args = append(args, s)

Original file line number	Diff line number	Diff line change
`@@ -1405,7 +1405,7 @@ func (c cmdable) XRevRangeN(stream, start, stop string, count int64) *XMessageSl`
`1405`	`1405`	`}`
`1406`	`1406`
`1407`	`1407`	`type XReadArgs struct {`
`1408`		`- Streams []string`
	`1408`	`+ Streams []string // list of streams and ids, e.g. stream1 stream2 id1 id2`
`1409`	`1409`	`Count int64`
`1410`	`1410`	`Block time.Duration`
`1411`	`1411`	`}`
`@@ -1421,6 +1421,7 @@ func (c cmdable) XRead(a XReadArgs) XStreamSliceCmd {`
`1421`	`1421`	`args = append(args, "block")`
`1422`	`1422`	`args = append(args, int64(a.Block/time.Millisecond))`
`1423`	`1423`	`}`
	`1424`	`+`
`1424`	`1425`	`args = append(args, "streams")`
`1425`	`1426`	`for _, s := range a.Streams {`
`1426`	`1427`	`args = append(args, s)`