mirror of https://github.com/waku-org/js-waku.git
fix: store
This commit is contained in:
parent
b8c5d27a3c
commit
1314930765
|
@ -309,9 +309,8 @@ async function* paginate<T extends DecodedMessage>(
|
||||||
}
|
}
|
||||||
|
|
||||||
let currentCursor = cursor;
|
let currentCursor = cursor;
|
||||||
|
|
||||||
while (true) {
|
while (true) {
|
||||||
queryOpts = Object.assign(queryOpts, { currentCursor });
|
queryOpts.cursor = currentCursor;
|
||||||
|
|
||||||
const stream = await connection.newStream(protocol);
|
const stream = await connection.newStream(protocol);
|
||||||
const historyRpcQuery = HistoryRPC.createQuery(queryOpts);
|
const historyRpcQuery = HistoryRPC.createQuery(queryOpts);
|
||||||
|
|
Loading…
Reference in New Issue