Method
xreadgroup
(
self: SyncClientProtocol,
groupname: str,
consumername: str,
streams: Dict[KeyT, StreamIdT],
count: int | None = None,
block: int | None = None,
noack: bool = False,
claim_min_idle_time: int | None = None,
)
Source from the content-addressed store, hash-verified
| 7703 | |
| 7704 | @overload |
| 7705 | def xreadgroup( |
| 7706 | self: SyncClientProtocol, |
| 7707 | groupname: str, |
| 7708 | consumername: str, |
| 7709 | streams: Dict[KeyT, StreamIdT], |
| 7710 | count: int | None = None, |
| 7711 | block: int | None = None, |
| 7712 | noack: bool = False, |
| 7713 | claim_min_idle_time: int | None = None, |
| 7714 | ) -> XReadGroupResponse: ... |
| 7715 | |
| 7716 | @overload |
| 7717 | def xreadgroup( |