Skip to content

Commit e4d36e7

Browse files
authored
Merge ca69055 into 3273c85
2 parents 3273c85 + ca69055 commit e4d36e7

File tree

2 files changed

+9
-5
lines changed

2 files changed

+9
-5
lines changed

packages/client/lib/commands/XINFO_CONSUMERS.spec.ts

+6-4
Original file line numberDiff line numberDiff line change
@@ -13,17 +13,19 @@ describe('XINFO CONSUMERS', () => {
1313
it('transformReply', () => {
1414
assert.deepEqual(
1515
transformReply([
16-
['name', 'Alice', 'pending', 1, 'idle', 9104628],
17-
['name', 'Bob', 'pending', 1, 'idle', 83841983]
16+
['name', 'Alice', 'pending', 1, 'idle', 9104628, 'inactive', 9281221],
17+
['name', 'Bob', 'pending', 1, 'idle', 83841983, 'inactive', 7213871]
1818
]),
1919
[{
2020
name: 'Alice',
2121
pending: 1,
22-
idle: 9104628
22+
idle: 9104628,
23+
inactive: 9281221,
2324
}, {
2425
name: 'Bob',
2526
pending: 1,
26-
idle: 83841983
27+
idle: 83841983,
28+
inactive: 7213871,
2729
}]
2830
);
2931
});

packages/client/lib/commands/XINFO_CONSUMERS.ts

+3-1
Original file line numberDiff line numberDiff line change
@@ -15,12 +15,14 @@ type XInfoConsumersReply = Array<{
1515
name: RedisCommandArgument;
1616
pending: number;
1717
idle: number;
18+
inactive: number;
1819
}>;
1920

2021
export function transformReply(rawReply: Array<any>): XInfoConsumersReply {
2122
return rawReply.map(consumer => ({
2223
name: consumer[1],
2324
pending: consumer[3],
24-
idle: consumer[5]
25+
idle: consumer[5],
26+
inactive: consumer[7]
2527
}));
2628
}

0 commit comments

Comments
 (0)