diff --git a/lib/Channel.js b/lib/Channel.js
index <HASH>..<HASH> 100644
--- a/lib/Channel.js
+++ b/lib/Channel.js
@@ -404,6 +404,7 @@ module.exports = Channel;
 
 
 function ChannelStream(channel) {
+  // TODO: update readable and writable appropriately
   var self = this;
   this.readable = true;
   this.writable = true;
@@ -449,6 +450,7 @@ ChannelStream.prototype.write = function(data, encoding, extended) {
 
 ChannelStream.prototype.pause = function() {
   this.paused = true;
+  this._channel._conn._sock.pause();
 };
 
 ChannelStream.prototype.resume = function() {
@@ -469,6 +471,8 @@ ChannelStream.prototype.resume = function() {
 
   if (ret === true)
     this.emit('drain');
+
+  this._channel._conn._sock.resume();
 };
 
 ChannelStream.prototype.end = function(data, encoding, extended) {
channel: pause/resume underlying socket when necessary