use self._taskQueue.queueTask instead of self._taskQueue.runTask

This commit is contained in:
denihs
2023-02-03 12:27:29 -04:00
parent 3e5977ce2b
commit b32ea404f1
2 changed files with 4 additions and 4 deletions

View File

@@ -809,14 +809,14 @@ Object.assign(Session.prototype, {
};
promise.then(result => {
finish().then(() => {
finish().finally(() => {
if (result !== undefined) {
payload.result = result;
}
self.send(payload);
});
}, (exception) => {
finish().then(() => {
finish().finally(() => {
payload.error = wrapInternalException(
exception,
`while invoking method '${msg.method}'`

View File

@@ -90,8 +90,8 @@ _.extend(PollingObserveDriver.prototype, {
if (self._pollsScheduledButNotStarted > 0)
return;
++self._pollsScheduledButNotStarted;
//TODO check this change
await self._taskQueue.runTask(async function () {
//TODO[fibers] check this change
await self._taskQueue.queueTask(async function () {
await self._pollMongo();
});
},