diff --git a/examples/cluster-threading-net-server.js b/examples/cluster-threading-net-server.js
index da9a2d1..4d49089 100644
--- a/examples/cluster-threading-net-server.js
+++ b/examples/cluster-threading-net-server.js
@@ -1,66 +1,65 @@
-const cluster = require('cluster');
-const ldap = require('ldapjs');
-const net = require('net');
-const os = require('os');
+const cluster = require('cluster')
+const ldap = require('ldapjs')
+const net = require('net')
+const os = require('os')
 
-const threads = [];
+const threads = []
 threads.getNext = function () {
-    return (Math.floor(Math.random() * this.length));
-};
+  return (Math.floor(Math.random() * this.length))
+}
 
 const serverOptions = {
-    port: 1389
-};
+  port: 1389
+}
 
 if (cluster.isMaster) {
-    const server = net.createServer(serverOptions, (socket) => {
-        socket.pause();
-        console.log('ldapjs client requesting connection');
-        let routeTo = threads.getNext();
-        threads[routeTo].send({ type: 'connection' }, socket);
-    });
+  const server = net.createServer(serverOptions, (socket) => {
+    socket.pause()
+    console.log('ldapjs client requesting connection')
+    const routeTo = threads.getNext()
+    threads[routeTo].send({ type: 'connection' }, socket)
+  })
 
-    for (let i = 0; i < os.cpus().length; i++) {
-        let thread = cluster.fork({
-            'id': i
-        });
-        thread.id = i;
-        thread.on('message', function (msg) {
+  for (let i = 0; i < os.cpus().length; i++) {
+    const thread = cluster.fork({
+      id: i
+    })
+    thread.id = i
+    thread.on('message', function () {
 
-        });
-        threads.push(thread);
+    })
+    threads.push(thread)
+  }
+
+  server.listen(serverOptions.port, function () {
+    console.log('ldapjs listening at ldap://127.0.0.1:' + serverOptions.port)
+  })
+} else {
+  const server = ldap.createServer(serverOptions)
+
+  const threadId = process.env.id
+
+  process.on('message', (msg, socket) => {
+    switch (msg.type) {
+      case 'connection':
+        server.newConnection(socket)
+        socket.resume()
+        console.log('ldapjs client connection accepted on ' + threadId.toString())
+    }
+  })
+
+  server.search('dc=example', function (req, res) {
+    console.log('ldapjs search initiated on ' + threadId.toString())
+    const obj = {
+      dn: req.dn.toString(),
+      attributes: {
+        objectclass: ['organization', 'top'],
+        o: 'example'
+      }
     }
 
-    server.listen(serverOptions.port, function () {
-        console.log('ldapjs listening at ldap://127.0.0.1:' + serverOptions.port);
-    });
-} else {
-    const server = ldap.createServer(serverOptions);
+    if (req.filter.matches(obj.attributes)) { res.send(obj) }
 
-    let threadId = process.env.id;
-
-    process.on('message', (msg, socket) => {
-        switch (msg.type) {
-            case 'connection':
-                server.newConnection(socket);
-                socket.resume();
-                console.log('ldapjs client connection accepted on ' + threadId.toString());
-        }
-    });
-
-    server.search('dc=example', function (req, res, next) {
-        console.log('ldapjs search initiated on ' + threadId.toString());
-        var obj = {
-            dn: req.dn.toString(),
-            attributes: {
-                objectclass: ['organization', 'top'],
-                o: 'example'
-            }
-        };
-
-        if (req.filter.matches(obj.attributes))
-            res.send(obj);
-
-        res.end();
-    });
+    res.end()
+  })
 }
diff --git a/examples/cluster-threading.js b/examples/cluster-threading.js
index b631c44..8def06a 100644
--- a/examples/cluster-threading.js
+++ b/examples/cluster-threading.js
@@ -1,66 +1,65 @@
-const cluster = require('cluster');
-const ldap = require('ldapjs');
-const os = require('os');
+const cluster = require('cluster')
+const ldap = require('ldapjs')
+const os = require('os')
 
-const threads = [];
+const threads = []
 threads.getNext = function () {
-    return (Math.floor(Math.random() * this.length));
-};
+  return (Math.floor(Math.random() * this.length))
+}
 
 const serverOptions = {
-    connectionRouter: (socket) => {
-        socket.pause();
-        console.log('ldapjs client requesting connection');
-        let routeTo = threads.getNext();
-        threads[routeTo].send({ type: 'connection' }, socket);
-    }
-};
+  connectionRouter: (socket) => {
+    socket.pause()
+    console.log('ldapjs client requesting connection')
+    const routeTo = threads.getNext()
+    threads[routeTo].send({ type: 'connection' }, socket)
+  }
+}
 
-const server = ldap.createServer(serverOptions);
+const server = ldap.createServer(serverOptions)
 
 if (cluster.isMaster) {
-    for (let i = 0; i < os.cpus().length; i++) {
-        let thread = cluster.fork({
-            'id': i
-        });
-        thread.id = i;
-        thread.on('message', function (msg) {
+  for (let i = 0; i < os.cpus().length; i++) {
+    const thread = cluster.fork({
+      id: i
+    })
+    thread.id = i
+    thread.on('message', function () {
 
-        });
-        threads.push(thread);
+    })
+    threads.push(thread)
+  }
+
+  server.listen(1389, function () {
+    console.log('ldapjs listening at ' + server.url)
+  })
+} else {
+  const threadId = process.env.id
+  serverOptions.connectionRouter = () => {
+    console.log('should not be hit')
+  }
+
+  process.on('message', (msg, socket) => {
+    switch (msg.type) {
+      case 'connection':
+        server.newConnection(socket)
+        socket.resume()
+        console.log('ldapjs client connection accepted on ' + threadId.toString())
+    }
+  })
+
+  server.search('dc=example', function (req, res) {
+    console.log('ldapjs search initiated on ' + threadId.toString())
+    const obj = {
+      dn: req.dn.toString(),
+      attributes: {
+        objectclass: ['organization', 'top'],
+        o: 'example'
+      }
     }
 
-    server.listen(1389, function () {
-        console.log('ldapjs listening at ' + server.url);
-    });
-} else {
-    let threadId = process.env.id;
-    serverOptions.connectionRouter = (connection) => {
-        console.log('should not be hit');
-    };
+    if (req.filter.matches(obj.attributes)) { res.send(obj) }
 
-    process.on('message', (msg, socket) => {
-        switch (msg.type) {
-            case 'connection':
-                server.newConnection(socket);
-                socket.resume();
-                console.log('ldapjs client connection accepted on ' + threadId.toString());
-        }
-    });
-
-    server.search('dc=example', function (req, res, next) {
-        console.log('ldapjs search initiated on ' + threadId.toString());
-        var obj = {
-            dn: req.dn.toString(),
-            attributes: {
-                objectclass: ['organization', 'top'],
-                o: 'example'
-            }
-        };
-
-        if (req.filter.matches(obj.attributes))
-            res.send(obj);
-
-        res.end();
-    });
+    res.end()
+  })
 }