diff --git a/redis.ts b/redis.ts index c83dd1a7..0a79b401 100644 --- a/redis.ts +++ b/redis.ts @@ -1922,8 +1922,8 @@ class RedisImpl implements Redis { consumer?: string, ) { const args = []; - args.push(startEndCount.start); - args.push(startEndCount.end); + args.push(xidstr(startEndCount.start)); + args.push(xidstr(startEndCount.end)); args.push(startEndCount.count); if (consumer) { diff --git a/stream.ts b/stream.ts index d0ae93f7..7676789b 100644 --- a/stream.ts +++ b/stream.ts @@ -137,8 +137,8 @@ export interface XPendingCount { * args must be specified if _any_ are specified. */ export interface StartEndCount { - start: number | "-"; - end: number | "+"; + start: XIdNeg; + end: XIdPos; count: number; }