summaryrefslogtreecommitdiff
path: root/worker.js
diff options
context:
space:
mode:
authorschneefux <schneefux+commit@schneefux.xyz>2017-08-20 12:08:06 +0200
committerschneefux <schneefux+commit@schneefux.xyz>2017-08-20 12:08:06 +0200
commit30d070c4958d14319ea214f4bb2dad8a1cae8d2c (patch)
tree292757761a2c840cb14f0dfb0482b605e5d5b34b /worker.js
parentdb8d2565a598f745ca59ecf1279d5b54a084118b (diff)
downloadcruncher-30d070c4958d14319ea214f4bb2dad8a1cae8d2c.tar.gz
cruncher-30d070c4958d14319ea214f4bb2dad8a1cae8d2c.zip
fix syntax error from last commit
Diffstat (limited to 'worker.js')
-rw-r--r--worker.js2
1 files changed, 1 insertions, 1 deletions
diff --git a/worker.js b/worker.js
index 9d40469..411958f 100644
--- a/worker.js
+++ b/worker.js
@@ -120,7 +120,7 @@ amqp.connect(RABBITMQ_URI).then(async (rabbit) => {
await Promise.map(msgs, async (m) => await ch.ack(m));
// notify web
// TODO notify for player too
- await Promise.map(api_ids, (id) => {
+ await Promise.map(api_ids, async (id) => {
await ch.publish("amq.topic",
"crunch." + id,
new Buffer("points_update"));