about summary refs log tree commit diff
path: root/streaming
diff options
context:
space:
mode:
authorYamagishi Kazutoshi <ykzts@desire.sh>2017-06-23 23:05:04 +0900
committerEugen Rochko <eugen@zeonfederated.com>2017-06-23 16:05:04 +0200
commiteff94164696ecb126ab47b85ee842e65692b649a (patch)
tree7cfb397d8d62e5d4ae96479505a74d1e15e41e00 /streaming
parent6fbb3841a6dd4ec3d84b098437e35f41d41e8407 (diff)
Remove unused variables (#3906)
Diffstat (limited to 'streaming')
-rw-r--r--streaming/index.js6
1 files changed, 3 insertions, 3 deletions
diff --git a/streaming/index.js b/streaming/index.js
index 5afdd5961..fb23be34d 100644
--- a/streaming/index.js
+++ b/streaming/index.js
@@ -242,7 +242,7 @@ const startWorker = (workerId) => {
     accountFromRequest(req, next);
   };
 
-  const errorMiddleware = (err, req, res, next) => {
+  const errorMiddleware = (err, req, res) => {
     log.error(req.requestId, err.toString());
     res.writeHead(err.statusCode || 500, { 'Content-Type': 'application/json' });
     res.end(JSON.stringify({ error: err.statusCode ? err.toString() : 'An unexpected error occurred' }));
@@ -366,7 +366,7 @@ const startWorker = (workerId) => {
       }
     });
 
-    ws.on('error', e => {
+    ws.on('error', () => {
       log.verbose(req.requestId, `Ending stream for ${req.accountId}`);
       unsubscribe(id, listener);
       if (closeHandler) {
@@ -443,7 +443,7 @@ const startWorker = (workerId) => {
     }
   });
 
-  const wsInterval = setInterval(() => {
+  setInterval(() => {
     wss.clients.forEach(ws => {
       if (ws.isAlive === false) {
         ws.terminate();