diff --git a/test/flatten.js b/test/flatten.js
index <HASH>..<HASH> 100644
--- a/test/flatten.js
+++ b/test/flatten.js
@@ -53,4 +53,20 @@ test('flatten stream of streams', function (t) {
 
 })
 
+test.only('flatten stream of broken streams', function (t) {
+  var _err = new Error('I am broken');
+  pull(
+    pull.values([
+      pull.Source(function read(abort, cb) {
+          cb(_err)  
+        })
+    ]),
+    pull.flatten(),
+    pull.onEnd(function (err) {
+      t.equal(err, _err)
+      t.end()
+    })
+  )
+
+})
Add failing test for flattening stream of broken streams