diff --git a/lib/internal/socket_list.js b/lib/internal/socket_list.js
index 950d632a26..0f4be6df23 100644
--- a/lib/internal/socket_list.js
+++ b/lib/internal/socket_list.js
@@ -58,13 +58,11 @@ SocketListSend.prototype.getConnections = function getConnections(callback) {
 function SocketListReceive(slave, key) {
   EventEmitter.call(this);
 
-  var self = this;
-
   this.connections = 0;
   this.key = key;
   this.slave = slave;
 
-  function onempty() {
+  function onempty(self) {
     if (!self.slave.connected) return;
 
     self.slave.send({
@@ -73,21 +71,21 @@ function SocketListReceive(slave, key) {
     });
   }
 
-  this.slave.on('internalMessage', function(msg) {
-    if (msg.key !== self.key) return;
+  this.slave.on('internalMessage', (msg) => {
+    if (msg.key !== this.key) return;
 
     if (msg.cmd === 'NODE_SOCKET_NOTIFY_CLOSE') {
       // Already empty
-      if (self.connections === 0) return onempty();
+      if (this.connections === 0) return onempty(this);
 
       // Wait for sockets to get closed
-      self.once('empty', onempty);
+      this.once('empty', onempty);
     } else if (msg.cmd === 'NODE_SOCKET_GET_COUNT') {
-      if (!self.slave.connected) return;
-      self.slave.send({
+      if (!this.slave.connected) return;
+      this.slave.send({
         cmd: 'NODE_SOCKET_COUNT',
-        key: self.key,
-        count: self.connections
+        key: this.key,
+        count: this.connections
       });
     }
   });
@@ -95,14 +93,12 @@ function SocketListReceive(slave, key) {
 util.inherits(SocketListReceive, EventEmitter);
 
 SocketListReceive.prototype.add = function(obj) {
-  var self = this;
-
   this.connections++;
 
   // Notify previous owner of socket about its state change
-  obj.socket.once('close', function() {
-    self.connections--;
+  obj.socket.once('close', () => {
+    this.connections--;
 
-    if (self.connections === 0) self.emit('empty');
+    if (this.connections === 0) this.emit('empty', this);
   });
 };