|
|
@ -68,8 +68,8 @@
|
|
|
|
const jobQueue = new window.JobQueue();
|
|
|
|
const jobQueue = new window.JobQueue();
|
|
|
|
|
|
|
|
|
|
|
|
const processMessages = async messages => {
|
|
|
|
const processMessages = async messages => {
|
|
|
|
const newMessages = await jobQueue.add(
|
|
|
|
const newMessages = await jobQueue.add(() =>
|
|
|
|
() => filterIncomingMessages(messages)
|
|
|
|
filterIncomingMessages(messages)
|
|
|
|
);
|
|
|
|
);
|
|
|
|
newMessages.forEach(async message => {
|
|
|
|
newMessages.forEach(async message => {
|
|
|
|
const { data } = message;
|
|
|
|
const { data } = message;
|
|
|
|