summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorschneefux <schneefux+commit@schneefux.xyz>2017-04-04 20:51:40 +0200
committerschneefux <schneefux+commit@schneefux.xyz>2017-04-04 20:51:40 +0200
commitc1b3c028e1284027ebc0e674e7c93cd0fd9e2d12 (patch)
tree2be7c7752bb97b59b553fca005d3cd8f5c20100a
parent2f5e0362d6fc9fbd4856838c9dd7667f34378117 (diff)
downloadprocessor-c1b3c028e1284027ebc0e674e7c93cd0fd9e2d12.tar.gz
processor-c1b3c028e1284027ebc0e674e7c93cd0fd9e2d12.zip
prevent possible race condition
-rw-r--r--worker.js2
1 files changed, 1 insertions, 1 deletions
diff --git a/worker.js b/worker.js
index 9aad2fe..eb41240 100644
--- a/worker.js
+++ b/worker.js
@@ -101,7 +101,7 @@ var RABBITMQ_URI = process.env.RABBITMQ_URI,
// data from `/player`
msgs.filter((m) => m.properties.type == "player").map((msg) => {
let players = JSON.parse(msg.content);
- players.map(async (p) => {
+ players.map((p) => {
let player = flatten(p);
console.log("processing player", player.name);
if (!is_in(player_records, player))