diff --git a/packages/client/lib/commands/XREAD.spec.ts b/packages/client/lib/commands/XREAD.spec.ts index b607f53532e..887422f3a9d 100644 --- a/packages/client/lib/commands/XREAD.spec.ts +++ b/packages/client/lib/commands/XREAD.spec.ts @@ -43,6 +43,29 @@ describe('XREAD', () => { ); }); + it('single stream last entry', () => { + assert.deepEqual( + transformArguments({ + key: 'key', + id: '+' + }), + ['XREAD', 'STREAMS', 'key', '+'] + ); + }); + + it('multiple streams last entry', () => { + assert.deepEqual( + transformArguments([{ + key: '1', + id: '+' + }, { + key: '2', + id: '+' + }]), + ['XREAD', 'STREAMS', '1', '2', '+', '+'] + ); + }); + it('with COUNT', () => { assert.deepEqual( transformArguments({