Change stream test to not require additional dependency

danmactough · Jun 11, 2013 · 0ae4bd4 · 0ae4bd4
1 parent 6f77076
commit 0ae4bd4
Showing 1 changed file with 9 additions and 6 deletions.
diff --git a/test/api-stream.js b/test/api-stream.js
@@ -1,5 +1,4 @@
 var fs = require('fs');
-var endpoint = require('endpoint');
 
 describe('Writeable Stream Input API', function () {
 
@@ -42,11 +41,15 @@ describe('Writeable Stream Input API', function () {
     it('works', function (done) {
       fs.createReadStream(feedPath)
         .pipe(FeedParser())
-        .pipe(endpoint({objectMode: true}, function (err, articles) {
+        .on('readable', function () {
-          assert.equal(err, null);
+          var stream = this, items = [], item;
-          assert.ok(articles.length);
+          while (item = stream.read()) {
-          done();
+            items.push(item);
-        }));
+          }
+          assert.ok(items.length);
+        })
+        .on('end', done)
+        .on('error', done);
     });
   });