diff --git a/lib/Channel.js b/lib/Channel.js
index <HASH>..<HASH> 100644
--- a/lib/Channel.js
+++ b/lib/Channel.js
@@ -515,8 +515,8 @@ function ChannelStream(channel) {
   this._sockOnEnd = function() {
     self.writable = false;
     self.readable = false;
-    channel._conn._sock.removeListener('end', this._sockOnEnd);
-    channel._conn._sock.removeListener('close', this._sockOnEnd);
+    channel._conn._sock.removeListener('end', self._sockOnEnd);
+    channel._conn._sock.removeListener('close', self._sockOnEnd);
   };
   channel._conn._sock.once('end', this._sockOnEnd);
   channel._conn._sock.once('close', this._sockOnEnd);
channel: fix incorrect 'this' usage