M
```
> XREAD BLOCK 0 STREAMS mystream $
```
А как это в обёртке редиса использовать? как передавать? каким порядком? через какую команду? как обрабатывать результат?
Интуитивно не варант. Это не удобно без доки с примерами…
Size: a a a
M
> XREAD BLOCK 0 STREAMS mystream $
IK
> XREAD BLOCK 0 STREAMS mystream $
M
IK
const commentStreamItem = await asyncXreadgroup(
"GROUP",
"comments-group",
"c1",
"COUNT",
"1",
"BLOCK",
1000,
"STREAMS",
"comments",
readingFlag
);
IK
const asyncXreadgroup = promisify(redisClient.xreadgroup).bind(redisClient);
IK
IK
0
, после первого прогона меняется на >
IK
M
const commentStreamItem = await asyncXreadgroup(
"GROUP",
"comments-group",
"c1",
"COUNT",
"1",
"BLOCK",
1000,
"STREAMS",
"comments",
readingFlag
);
IK
IK
IK
M
VS
function someCtor(someModule) {
return function doSomething() {
return someModule();
}
}
// VS
const someModule = require('./some-module');
function doSomething() {
return someModule();
}
С
С
PS
TS
VS
TS