re
/
redis
forked from mirror/redis
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Support XREAD BLOCK 0

This commit is contained in:
Vladimir Mihailenco 2018-07-18 12:08:43 +03:00
parent ab1a52f0c9
commit 1932888b44
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
commands.go
View File

@ -1376,7 +1376,7 @@ func (c *cmdable) XReadExt(opt *XReadExt) *XStreamSliceCmd {
a = append(a, "count") a = append(a, "count")
a = append(a, opt.Count) a = append(a, opt.Count)
} }
if opt.Block > 0 { if opt.Block >= 0 {
a = append(a, "block") a = append(a, "block")
a = append(a, int64(opt.Block/time.Millisecond)) a = append(a, int64(opt.Block/time.Millisecond))
} }
@ -1394,6 +1394,7 @@ func (c *cmdable) XReadExt(opt *XReadExt) *XStreamSliceCmd {
func (c *cmdable) XRead(streams ...string) *XStreamSliceCmd { func (c *cmdable) XRead(streams ...string) *XStreamSliceCmd {
return c.XReadExt(&XReadExt{ return c.XReadExt(&XReadExt{
Streams: streams, Streams: streams,
Block: -1,
}) })
} }
@ -1401,6 +1402,7 @@ func (c *cmdable) XReadN(count int64, streams ...string) *XStreamSliceCmd {
return c.XReadExt(&XReadExt{ return c.XReadExt(&XReadExt{
Streams: streams, Streams: streams,
Count: count, Count: count,
Block: -1,
}) })
} }