We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 04027a8 commit 7fc22b9Copy full SHA for 7fc22b9
plugins/push/api/send/pool.js
@@ -290,7 +290,7 @@ class Pool extends Duplex {
290
let unsent = this.state.messages().filter(m => mids.indexOf(m._id.toString()) === -1);
291
if (unsent.length) {
292
this.log.i('Sending unsent messages to %s: %j', connection.worker.threadId, unsent);
293
- connection.write(encode(FRAME.CONNECT, unsent.map(id => this.state.messages().filter(m => m._id.toString() === id)[0])));
+ connection.write(encode(FRAME.CONNECT, unsent.map(_m => this.state.messages().filter(m => m._id.toString() === _m._id.toString())[0])));
294
}
295
return connection;
296
0 commit comments