diff --git a/lib/topic-readable.js b/lib/topic-readable.js
index <HASH>..<HASH> 100644
--- a/lib/topic-readable.js
+++ b/lib/topic-readable.js
@@ -209,6 +209,6 @@ TopicReadable.prototype.close = function(cb) {
     if (!self.unsubscribed) {
       self.consumer.unsubscribe();
     }
-    self.emit('closed');
+    self.emit('close');
   }
 };
diff --git a/test/topic-readable.spec.js b/test/topic-readable.spec.js
index <HASH>..<HASH> 100644
--- a/test/topic-readable.spec.js
+++ b/test/topic-readable.spec.js
@@ -159,8 +159,16 @@ module.exports = {
       stream.on('end', function() {
         next();
       });
-    }
+    },
+
+    'calls the callback on close': function (next) {
 
+      fakeClient.unsubscribe = function () {};
+      var stream = new TopicReadable(fakeClient, 'topic');
+      stream.once('readable', function () {
+        stream.close(next);
+      });
 
-  },
+    },
+  }
 };
Closing the TopicReadable calls the callback (#<I>)