Added #pendingListIdleMoreThan:limit: to RsStreamConsumerGroup

mumez · Sep 17, 2024 · 4a7f389 · 4a7f389
1 parent 7c6f1d7
commit 4a7f389
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 2 deletions.
diff --git a/...ry/RediStick-Stream-Objects.package/RsStreamConsumerGroup.class/instance/consumersInfo.st b/...ry/RediStick-Stream-Objects.package/RsStreamConsumerGroup.class/instance/consumersInfo.st
@@ -1,3 +1,5 @@
 consumers
 consumersInfo
-	^ self endpoint xInfoConsumers: self streamName group: self name
+	| consumersInfo |
+	consumersInfo :=  self endpoint xInfoConsumers: self streamName group: self name.
+	^ consumersInfo inject: Dictionary new into: [ :sum :each | sum at: each name put: each; yourself ]
diff --git a/...am-Objects.package/RsStreamConsumerGroup.class/instance/pendingListIdleMoreThan.limit..st b/...am-Objects.package/RsStreamConsumerGroup.class/instance/pendingListIdleMoreThan.limit..st
@@ -0,0 +1,3 @@
+accessing-pending-list
+pendingListIdleMoreThan: milliseconds limit: count
+	^ self endpoint xPending: self streamName group: self name start: RsStreamMessageId min end: RsStreamMessageId max count: count minIdleMilliseconds: milliseconds
diff --git a/...ediStick-Stream-Objects.package/RsStreamConsumerGroup.class/instance/pendingsAfter.on..st b/...ediStick-Stream-Objects.package/RsStreamConsumerGroup.class/instance/pendingsAfter.on..st
@@ -1,6 +1,6 @@
 reading
 pendingsAfter: latestMessageId on: consumerName
-	^ self wrapAsAcceptableEntries: ( self endpoint
+	^ self wrapAsAcceptableEntries: (self endpoint
 		  xGroupRead: self streamName
 		  id: latestMessageId
 		  group: self name