XReadGroupCommand extension
- on
-
- StreamCommands
Methods
-
xReadGroup(
String group, String consumer, List< String> keys, List<String> ids, {int? count, int? block, bool noAck = false}) → Future<Map< String, List< >StreamEntry> > -
Available on StreamCommands, provided by the XReadGroupCommand extension
XREADGROUP GROUP group consumerCOUNT countBLOCK milliseconds[NOACK]STREAMS keykey ...idid ...