Skip to content

Commit dc6c4b3

Browse files
fix: do not omit arg if value is 0 (#435)
1 parent 1de1e37 commit dc6c4b3

File tree

1 file changed

+7
-7
lines changed

1 file changed

+7
-7
lines changed

redis.ts

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -1825,7 +1825,7 @@ class RedisImpl implements Redis {
18251825

18261826
xinfoStreamFull(key: string, count?: number) {
18271827
const args = [];
1828-
if (count) {
1828+
if (count !== undefined) {
18291829
args.push("COUNT");
18301830
args.push(count);
18311831
}
@@ -1941,7 +1941,7 @@ class RedisImpl implements Redis {
19411941
count?: number,
19421942
) {
19431943
const args: (string | number)[] = [key, xidstr(start), xidstr(end)];
1944-
if (count) {
1944+
if (count !== undefined) {
19451945
args.push("COUNT");
19461946
args.push(count);
19471947
}
@@ -1957,7 +1957,7 @@ class RedisImpl implements Redis {
19571957
count?: number,
19581958
) {
19591959
const args: (string | number)[] = [key, xidstr(start), xidstr(end)];
1960-
if (count) {
1960+
if (count !== undefined) {
19611961
args.push("COUNT");
19621962
args.push(count);
19631963
}
@@ -1972,11 +1972,11 @@ class RedisImpl implements Redis {
19721972
) {
19731973
const args = [];
19741974
if (opts) {
1975-
if (opts.count) {
1975+
if (opts.count !== undefined) {
19761976
args.push("COUNT");
19771977
args.push(opts.count);
19781978
}
1979-
if (opts.block) {
1979+
if (opts.block !== undefined) {
19801980
args.push("BLOCK");
19811981
args.push(opts.block);
19821982
}
@@ -2014,11 +2014,11 @@ class RedisImpl implements Redis {
20142014
consumer,
20152015
];
20162016

2017-
if (count) {
2017+
if (count !== undefined) {
20182018
args.push("COUNT");
20192019
args.push(count);
20202020
}
2021-
if (block) {
2021+
if (block !== undefined) {
20222022
args.push("BLOCK");
20232023
args.push(block);
20242024
}

0 commit comments

Comments
 (0)