{Request,Response}::body_form

Author: yoshuawuyts

src/body.rs

@@ -193,7 +193,7 @@ impl Body {
     /// let mut req = Response::new(StatusCode::Ok);
     ///
     /// let input = String::from("hello Nori!");
-    /// req.set_body(Body::from_bytes(input));
+    /// req.set_body(Body::from_string(input));
     /// ```
     pub fn from_string(s: String) -> Self {
         Self {
@@ -262,7 +262,7 @@ impl Body {
     /// struct Cat { name: String }
     ///
     /// let cat = Cat { name: String::from("chashu") };
-    /// let body = Body::from_json(cat)?;
+    /// let body = Body::from_json(&cat)?;
     ///
     /// let cat: Cat = body.into_json().await?;
     /// assert_eq!(&cat.name, "chashu");
@@ -331,7 +331,7 @@ impl Body {
     /// struct Cat { name: String }
     ///
     /// let cat = Cat { name: String::from("chashu") };
-    /// let body = Body::from_form(cat)?;
+    /// let body = Body::from_form(&cat)?;
     ///
     /// let cat: Cat = body.into_form().await?;
     /// assert_eq!(&cat.name, "chashu");

src/request.rs

@@ -271,7 +271,7 @@ impl Request {
     ///
     /// let cat = Cat { name: String::from("chashu") };
     /// let mut req = Request::new(Method::Get, Url::parse("https://example.com").unwrap());
-    /// req.set_body(Body::from_json(cat)?);
+    /// req.set_body(Body::from_json(&cat)?);
     ///
     /// let cat: Cat = req.body_json().await?;
     /// assert_eq!(&cat.name, "chashu");
@@ -281,6 +281,35 @@ impl Request {
         self.body.into_json().await
     }
 
+    /// Read the body as `x-www-form-urlencoded`.
+    ///
+    /// This consumes the request. If you want to read the body without
+    /// consuming the request, consider using the `take_body` method and
+    /// then calling `Body::into_json` or using the Request's AsyncRead
+    /// implementation to read the body.
+    ///
+    /// # Examples
+    ///
+    /// ```
+    /// # fn main() -> Result<(), http_types::Error> { async_std::task::block_on(async {
+    /// use http_types::{Body, Url, Method, Request};
+    /// use http_types::convert::{Serialize, Deserialize};
+    ///
+    /// #[derive(Debug, Serialize, Deserialize)]
+    /// struct Cat { name: String }
+    ///
+    /// let cat = Cat { name: String::from("chashu") };
+    /// let mut req = Request::new(Method::Get, Url::parse("https://example.com").unwrap());
+    /// req.set_body(Body::from_form(&cat)?);
+    ///
+    /// let cat: Cat = req.body_form().await?;
+    /// assert_eq!(&cat.name, "chashu");
+    /// # Ok(()) }) }
+    /// ```
+    pub async fn body_form<T: DeserializeOwned>(self) -> crate::Result<T> {
+        self.body.into_form().await
+    }
+
     /// Get an HTTP header.
     pub fn header(&self, name: &HeaderName) -> Option<&HeaderValues> {
         self.headers.get(name)

src/response.rs

@@ -300,7 +300,7 @@ impl Response {
     ///
     /// let cat = Cat { name: String::from("chashu") };
     /// let mut res = Response::new(StatusCode::Ok);    
-    /// res.set_body(Body::from_json(cat)?);
+    /// res.set_body(Body::from_json(&cat)?);
     ///
     /// let cat: Cat = res.body_json().await?;
     /// assert_eq!(&cat.name, "chashu");
@@ -310,6 +310,35 @@ impl Response {
         self.body.into_json().await
     }
 
+    /// Read the body as `x-www-form-urlencoded`.
+    ///
+    /// This consumes the request. If you want to read the body without
+    /// consuming the request, consider using the `take_body` method and
+    /// then calling `Body::into_json` or using the Response's AsyncRead
+    /// implementation to read the body.
+    ///
+    /// # Examples
+    ///
+    /// ```
+    /// # fn main() -> Result<(), http_types::Error> { async_std::task::block_on(async {
+    /// use http_types::{Body, Url, Method, Response, StatusCode};    
+    /// use http_types::convert::{Serialize, Deserialize};
+    ///
+    /// #[derive(Debug, Serialize, Deserialize)]
+    /// struct Cat { name: String }
+    ///
+    /// let cat = Cat { name: String::from("chashu") };
+    /// let mut res = Response::new(StatusCode::Ok);    
+    /// res.set_body(Body::from_form(&cat)?);
+    ///
+    /// let cat: Cat = res.body_form().await?;
+    /// assert_eq!(&cat.name, "chashu");
+    /// # Ok(()) }) }
+    /// ```
+    pub async fn body_form<T: DeserializeOwned>(self) -> crate::Result<T> {
+        self.body.into_form().await
+    }
+
     /// Set the response MIME.
     pub fn set_content_type(&mut self, mime: Mime) -> Option<HeaderValues> {
         let value: HeaderValue = mime.into();