Make API compatible with previous version

Author: fbbdev

lib/request.js

@@ -120,7 +120,9 @@ Request.prototype._createReqRes = function () {
         if (HEADER_EXPR.test(param) || param === 'CONTENT_LENGTH' || param === 'CONTENT_TYPE') {
             var name = param.slice(5).replace(UNDERSCORE_EXPR, '-');
             var value = this.params[param];
-            raw.push(name, value);
+            if (raw) {
+                raw.push(name, value);
+            }
             this._req._addHeaderLine(name, value, dest);
         }
     }
@@ -166,6 +168,10 @@ Request.prototype._createReqRes = function () {
     this._res.stdout = this;
     this._res.stderr = this.errorStream;
 
+    if (this._req.complete) {
+        process.nextTick(this._req.emit.bind(this._req, 'complete'));
+    }
+
     return { req: this._req, res: this._res };
 }
 

lib/server.js

@@ -321,6 +321,10 @@ function recordHandler(conn, req, record) {
             req._stdinComplete = true;
             if (req._req) {
                 req._req.complete = req._stdinComplete && req._dataComplete;
+                // NOTE: Backward compatibility
+                if (req._req.complete) {
+                    req._req.emit('complete');
+                }
             }
         }
 
@@ -338,6 +342,10 @@ function recordHandler(conn, req, record) {
             req._dataComplete = true;
             if (req._req) {
                 req._req.complete = req._stdinComplete && req._dataComplete;
+                // NOTE: Backward compatibility
+                if (req._req.complete) {
+                    req._req.emit('complete');
+                }
             }
         }