Add + Send to futures (#32)

Author: KiriosK

src/client/mod.rs

@@ -130,7 +130,7 @@ impl Client {
     /// Pings the InfluxDB Server
     ///
     /// Returns a tuple of build type and version number
-    pub fn ping(&self) -> impl Future<Item = (String, String), Error = Error> {
+    pub fn ping(&self) -> impl Future<Item = (String, String), Error = Error> + Send {
         ReqwestClient::new()
             .get(format!("{}/ping", self.url).as_str())
             .send()
@@ -180,7 +180,7 @@ impl Client {
     /// a [`Error`] variant will be returned.
     ///
     /// [`Error`]: enum.Error.html
-    pub fn query<'q, Q>(&self, q: &'q Q) -> Box<dyn Future<Item = String, Error = Error>>
+    pub fn query<'q, Q>(&self, q: &'q Q) -> Box<dyn Future<Item = String, Error = Error> + Send>
     where
         Q: Query,
         &'q Q: Into<QueryTypes<'q>>,

src/integrations/serde_integration.rs

@@ -75,9 +75,11 @@ pub struct DatabaseQueryResult {
 }
 
 impl DatabaseQueryResult {
-    pub fn deserialize_next<T: 'static>(&mut self) -> impl Future<Item = Return<T>, Error = Error>
+    pub fn deserialize_next<T: 'static>(
+        &mut self,
+    ) -> impl Future<Item = Return<T>, Error = Error> + Send
     where
-        T: DeserializeOwned,
+        T: DeserializeOwned + Send,
     {
         match serde_json::from_value::<Return<T>>(self.results.remove(0)) {
             Ok(item) => futures::future::result(Ok(item)),
@@ -105,7 +107,7 @@ impl Client {
     pub fn json_query(
         &self,
         q: ReadQuery,
-    ) -> impl Future<Item = DatabaseQueryResult, Error = Error> {
+    ) -> impl Future<Item = DatabaseQueryResult, Error = Error> + Send {
         use futures::future;
 
         let query = q.build().unwrap();