feat!: use 'IntoFuture' trait to await futures directly without calling 'send'

examples/list_transactions.rs

@@ -23,7 +23,6 @@ async fn main() -> monzo::Result<()> {
         .transactions(account_id)
         .since(Utc::now() - Duration::try_days(args.days).unwrap())
         .limit(args.limit)
-        .send()
         .await?;
 
     println!("account: {account_id}");

src/client.rs

@@ -183,7 +183,6 @@ where
     /// client
     ///     .basic_feed_item(account_id, title, image_url)
     ///     .body("i figured out how to send messages to monzo from my computer...")
-    ///     .send()
     ///     .await?;
     /// #
     /// # Ok(())
@@ -242,7 +241,6 @@ where
     ///     .transactions(account_id)
     ///     .since(Utc::now() - Duration::days(10))
     ///     .limit(10)
-    ///     .send()
     ///     .await?;
     /// #
     /// # Ok(())
@@ -269,7 +267,7 @@ where
     /// #
     /// let transaction_id = "TRANSACTION_ID";
     ///
-    /// let transactions = client.transaction(transaction_id).send().await?;
+    /// let transactions = client.transaction(transaction_id).await?;
     /// #
     /// # Ok(())
     /// # }

src/endpoints/feed_items.rs

@@ -3,6 +3,8 @@
 pub use basic::Request as Basic;
 
 pub(crate) mod basic {
+    use std::future::{Future, IntoFuture};
+
     use serde::Serialize;
 
     use crate::{client, endpoints::Endpoint, Result};
@@ -99,11 +101,6 @@
             self.payload.params.body = Some(body);
             self
         }
-
-        /// Consume and send the [`Request`].
-        pub async fn send(self) -> Result<()> {
-            self.client.handle_request(&self).await
-        }
     }
 
     impl<C> Endpoint for Request<'_, C>
@@ -121,6 +118,20 @@
         }
     }
 
+    impl<'a, C> IntoFuture for Request<'a, C>
+    where
+        C: client::Inner,
+    {
+        type Output = Result<()>;
+
+        type IntoFuture = impl Future<Output = Self::Output>;
+
+        /// Consume and send the [`Request`].
+        fn into_future(self) -> Self::IntoFuture {
+            async move { self.client.handle_request(&self).await }
+        }
+    }
+
     #[derive(Debug, Serialize)]
     struct Params<'a> {
         #[serde(rename = "params[title]")]

src/endpoints/transactions/get.rs

@@ -1,3 +1,5 @@
+use std::future::{Future, IntoFuture};
+
 use super::Transaction;
 use crate::{client, endpoints::Endpoint, Result};
 
@@ -53,9 +55,18 @@
         self.expand_merchant = true;
         self
     }
+}
+
+impl<'a, C> IntoFuture for Request<'a, C>
+where
+    C: client::Inner,
+{
+    type Output = Result<Transaction>;
+
+    type IntoFuture = impl Future<Output = Self::Output>;
 
     /// Consume the request and return the [`Transaction`]
-    pub async fn send(self) -> Result<Transaction> {
-        self.client.handle_request(&self).await
+    fn into_future(self) -> Self::IntoFuture {
+        async move { self.client.handle_request(&self).await }
     }
 }

src/endpoints/transactions/list.rs

@@ -1,3 +1,5 @@
+use std::future::{Future, IntoFuture};
+
 use chrono::{DateTime, Utc};
 use serde::{Deserialize, Serialize};
 
@@ -78,17 +80,26 @@
         self.query.expand_merchant = Some("merchant");
         self
     }
+}
+
+impl<'a, C> IntoFuture for Request<'a, C>
+where
+    C: client::Inner,
+{
+    type Output = Result<Vec<Transaction>>;
+
+    type IntoFuture = impl Future<Output = Self::Output>;
 
     /// Consume the request and return the list of [`Transaction`]s
-    pub async fn send(self) -> Result<Vec<Transaction>> {
+    fn into_future(self) -> Self::IntoFuture {
         #[derive(Deserialize)]
         struct Response {
             transactions: Vec<Transaction>,
         }
-
-        let response: Response = self.client.handle_request(&self).await?;
-
-        Ok(response.transactions)
+        async move {
+            let response: Response = self.client.handle_request(&self).await?;
+            Ok(response.transactions)
+        }
     }
 }
 

src/lib.rs

@@ -8,6 +8,7 @@
 #![warn(clippy::pedantic)]
 #![warn(clippy::nursery)]
 #![allow(clippy::missing_errors_doc)]
+
 #![doc = include_str!("../README.md")]
 
 mod client;