diff --git a/lib/collect.js b/lib/collect.js
index 6245e6c..e5d4f35 100644
--- a/lib/collect.js
+++ b/lib/collect.js
@@ -3,6 +3,8 @@ module.exports = collect
 function collect (stream) {
   if (stream._collected) return
 
+  if (stream._paused) return stream.on('resume', collect.bind(null, stream))
+
   stream._collected = true
   stream.pause()