Expose bytes to the Response object

This patch exposes the `Response::bytes`, which is basically a wrapper
on reqwest::Response::bytes().

Author: laurocaetano

elasticsearch/src/http/response.rs

@@ -21,6 +21,7 @@ use crate::{
     error::Error as ClientError,
     http::{headers::HeaderMap, Method, StatusCode, Url},
 };
+use bytes::Bytes;
 use serde::{
     de,
     de::{DeserializeOwned, MapAccess, Visitor},
@@ -128,6 +129,14 @@ impl Response {
         Ok(body)
     }
 
+    /// Asynchronously reads the response body as bytes
+    ///
+    /// Reading the response body consumes `self`
+    pub async fn bytes(self) -> Result<Bytes, ClientError> {
+        let bytes: Bytes = self.response.bytes().await?;
+        Ok(bytes)
+    }
+
     /// Gets the request URL
     pub fn url(&self) -> &Url {
         self.response.url()

elasticsearch/tests/client.rs

@@ -32,6 +32,7 @@ use elasticsearch::{
 };
 
 use crate::common::client::index_documents;
+use bytes::Bytes;
 use hyper::Method;
 use serde_json::{json, Value};
 use std::time::Duration;
@@ -309,6 +310,33 @@ async fn search_with_no_body() -> Result<(), failure::Error> {
     Ok(())
 }
 
+#[tokio::test]
+async fn read_response_as_bytes() -> Result<(), failure::Error> {
+    let client = client::create_default();
+    let _ = index_documents(&client).await?;
+    let response = client
+        .search(SearchParts::None)
+        .pretty(true)
+        .q("title:Elasticsearch")
+        .send()
+        .await?;
+
+    assert_eq!(response.status_code(), StatusCode::OK);
+    assert_eq!(response.method(), elasticsearch::http::Method::Get);
+
+    let response: Bytes = response.bytes().await?;
+
+    let json: Value = serde_json::from_slice(&response).unwrap();
+
+    assert!(json["took"].as_i64().is_some());
+
+    for hit in json["hits"]["hits"].as_array().unwrap() {
+        assert!(hit["_source"]["title"].as_str().is_some());
+    }
+
+    Ok(())
+}
+
 #[tokio::test]
 async fn cat_health_format_json() -> Result<(), failure::Error> {
     let client = client::create_default();