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"
   },