From 5001e0833d5cee5ea8cd352e8f23260a1a16de9a Mon Sep 17 00:00:00 2001
From: Josiah <josiah@rapidapps.io>
Date: Tue, 25 Aug 2015 08:04:48 +0100
Subject: [PATCH] Test that gulp-rename works for parallel streams

---
 test/rename.spec.js | 47 +++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 47 insertions(+)

diff --git a/test/rename.spec.js b/test/rename.spec.js
index b77637b..13db924 100644
--- a/test/rename.spec.js
+++ b/test/rename.spec.js
@@ -2,6 +2,9 @@
 /* global helper, helperError */
 
 require('./spec-helper');
+var rename = require('../');
+var gulp = require('gulp');
+var Path = require('path');
 
 describe('gulp-rename', function () {
   context('with string parameter', function () {
@@ -172,6 +175,50 @@ describe('gulp-rename', function () {
     });
   });
 
+  context('in parallel streams', function () {
+    it('only changes the file in the current stream', function (done) {
+      var files = gulp.src('test/fixtures/hello.txt');
+
+      var pipe1 = files.pipe(rename({suffix: '-1'}));
+      var pipe2 = files.pipe(rename({suffix: '-2'}));
+      var end1 = false;
+      var end2 = false;
+      var file1;
+      var file2;
+
+      pipe1
+        .on('data', function (file) {
+          file1 = file;
+        })
+        .on('end', function () {
+          end1 = true;
+
+          if (end2) {
+            return check();
+          }
+        });
+
+      pipe2
+        .on('data', function (file) {
+          file2 = file;
+        })
+        .on('end', function () {
+          end2 = true;
+
+          if (end1) {
+            return check();
+          }
+        });
+
+      function check() {
+        file1.path.should.equal(Path.resolve('test/fixtures/hello-1.txt'));
+        file2.path.should.equal(Path.resolve('test/fixtures/hello-2.txt'));
+
+        return done();
+      }
+    });
+  });
+
   context('throws unsupported parameter type', function () {
     var srcPattern;
     beforeEach(function () {