Add Stream#parseForm()

lib/adapters/node/lang.js

@@ -1,6 +1,9 @@
 if (typeof define !== 'function') { var define = (require('amdefine'))(module); }
 
-define(function(require, exports){
+define([
+  "exports",
+  "querystring"
+], function(exports, querystring){
   "use strict";
 
   var slice = [].slice;
@@ -59,4 +62,8 @@ define(function(require, exports){
   exports.parseJSON = function(str){
     return JSON.parse(str);
   };
+
+  exports.parseForm = function(str){
+    return querystring.parse(str);
+  };
 });

stream/Stream.js

@@ -525,6 +525,17 @@ define([
     **/
     parseJSON: function(){
       return later(this.join(""), lang.parseJSON);
+    },
+
+    /**
+    * stream.Stream#parseForm() -> promise.Promise
+    *
+    * Joins the stream into a string and then parses it as if it were
+    * form-urlencoded. Always returns a promise so parse errors can be handled
+    * more gracefully.
+    **/
+    parseForm: function(){
+      return later(this.join(""), lang.parseForm);
     }
   });
 

test/stream-utils/makeStreamTest.js

@@ -1112,6 +1112,28 @@ define([
         }
       },
 
+      "parseForm": {
+        beforeEach: function(){
+          values.splice(0, 3, 'foo=', 'bar&ba', 'z=thud');
+        },
+
+        "returns promise": function(){
+          finish();
+          var promise = instance.parseForm();
+          assert(isPromise(promise));
+          refute(promise.isFulfilled());
+          return promise;
+        },
+
+        "parses": function(){
+          finish();
+          return instance.parseForm().then(function(json){
+            assert.same(json.foo, "bar");
+            assert.same(json.baz, "thud");
+          });
+        }
+      },
+
       "isRepeatable": {
         "returns expected value": function(){
           assert.same(instance.isRepeatable(), repeatable);