Skip to content

Commit 958328b

Browse files
committed
simple int test
1 parent 19c928f commit 958328b

File tree

2 files changed

+3
-4
lines changed

2 files changed

+3
-4
lines changed

cmd_stream.go

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1313,10 +1313,6 @@ func writeXpending(
13131313
})
13141314
}
13151315
}
1316-
if len(res) == 0 {
1317-
c.WriteLen(0)
1318-
return
1319-
}
13201316
c.WriteLen(len(res))
13211317
for _, e := range res {
13221318
c.WriteLen(4)

integration/stream_test.go

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -587,6 +587,9 @@ func TestStreamGroup(t *testing.T) {
587587
c.Do("XGROUP", "DELCONSUMER", "planets", "processing", "alice")
588588
c.Do("XPENDING", "planets", "processing")
589589

590+
c.Do("XGROUP", "CREATE", "empty", "empty", "$", "MKSTREAM")
591+
c.Do("XPENDING", "empty", "empty", "-", "+", "999")
592+
590593
c.Error("consumer group", "XPENDING", "foo", "processing")
591594
c.Error("consumer group", "XPENDING", "planets", "foo")
592595

0 commit comments

Comments
 (0)