method

RedisClient.xreadgroup

...args: string | number[]

): Promise<any>;

Read entries from one or more streams using a consumer group

@param args

GROUP groupname consumername, optional COUNT/BLOCK/NOACK, STREAMS keyword, keys, and IDs

@returns

Promise that resolves with stream entries, or null if BLOCK timed out

await redis.xreadgroup("GROUP", "mygroup", "consumer1", "COUNT", 10, "STREAMS", "mystream", ">");