From 92848347e8cd187335c5a89116527d446a13128f Mon Sep 17 00:00:00 2001
From: Stephen Sawchuk <sawchuk@gmail.com>
Date: Tue, 18 Aug 2015 20:58:56 -0400
Subject: [PATCH] core: update streamforward

---
 lib/common/util.js | 6 +++++-
 package.json       | 4 ++--
 2 files changed, 7 insertions(+), 3 deletions(-)

diff --git a/lib/common/util.js b/lib/common/util.js
index e81f1e0b072..0943bc75174 100644
--- a/lib/common/util.js
+++ b/lib/common/util.js
@@ -567,7 +567,11 @@ function makeRequest(reqOpts, config, callback) {
 
     // `streamForward` is used to re-emit the events the request stream receives
     // on to the stream the user is holding (config.stream).
-    streamForward(requestStream).pipe(config.stream);
+    var streamForwardOpts = {
+      events: ['error', 'response', 'complete']
+    };
+
+    streamForward(requestStream, streamForwardOpts).pipe(config.stream);
   } else {
     retryRequest(reqOpts, options, function(err, response, body) {
       util.handleResp(err, response, body, callback);
diff --git a/package.json b/package.json
index 7f38f1a5815..cf9ee361106 100644
--- a/package.json
+++ b/package.json
@@ -66,11 +66,11 @@
     "propprop": "^0.3.0",
     "protobufjs": "^3.8.2",
     "request": "^2.53.0",
-    "retry-request": "^1.1.0",
+    "retry-request": "^1.2.1",
     "split-array-stream": "^1.0.0",
     "sse4_crc32": "^3.1.0",
     "stream-events": "^1.0.1",
-    "stream-forward": "^2.0.0",
+    "stream-forward": "^3.0.0",
     "string-format-obj": "^1.0.0",
     "through2": "^2.0.0"
   },