use 'IntoFutre' trait

examples/list_transactions.rs

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

src/client.rs

@@ -149,7 +149,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(())
@@ -212,7 +211,6 @@ where
     ///     .transactions(account_id)
     ///     .since(Utc::now() - Duration::days(10))
     ///     .limit(10)
-    ///     .send()
     ///     .await?;
     /// #
     /// # Ok(())
@@ -239,7 +237,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, client::handle_request, endpoints::Endpoint, Result};
@@ -95,7 +97,7 @@ pub(crate) mod basic {
         }
 
         /// Consume and send the [`Request`].
-        pub async fn send(self) -> Result<()> {
+        async fn send(self) -> Result<()> {
             handle_request(self.client, &self).await
         }
     }
@@ -114,6 +116,16 @@ pub(crate) mod basic {
         }
     }
 
+    impl<'a> IntoFuture for Request<'a> {
+        type Output = Result<()>;
+
+        type IntoFuture = impl Future<Output = Self::Output>;
+
+        fn into_future(self) -> Self::IntoFuture {
+            self.send()
+        }
+    }
+
     #[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::{self, handle_request},
@@ -52,7 +54,17 @@ impl<'a> Request<'a> {
     }
 
     /// Consume the request and return the [`Transaction`]
-    pub async fn send(self) -> Result<Transaction> {
+    async fn send(self) -> Result<Transaction> {
         handle_request(self.client, &self).await
     }
 }
+
+impl<'a> IntoFuture for Request<'a> {
+    type Output = Result<Transaction>;
+
+    type IntoFuture = impl Future<Output = Self::Output>;
+
+    fn into_future(self) -> Self::IntoFuture {
+        self.send()
+    }
+}

src/endpoints/transactions/list.rs

@@ -1,3 +1,5 @@
+use std::future::{Future, IntoFuture};
+
 use chrono::{DateTime, Utc};
 use serde::{Deserialize, Serialize};
 
@@ -77,7 +79,7 @@ impl<'a> Request<'a> {
     }
 
     /// Consume the request and return the list of [`Transaction`]s
-    pub async fn send(self) -> Result<Vec<Transaction>> {
+    async fn send(self) -> Result<Vec<Transaction>> {
         #[derive(Deserialize)]
         struct Response {
             transactions: Vec<Transaction>,
@@ -89,6 +91,16 @@ impl<'a> Request<'a> {
     }
 }
 
+impl<'a> IntoFuture for Request<'a> {
+    type Output = Result<Vec<Transaction>>;
+
+    type IntoFuture = impl Future<Output = Self::Output>;
+
+    fn into_future(self) -> Self::IntoFuture {
+        self.send()
+    }
+}
+
 #[derive(Serialize, Debug)]
 struct Query<'a> {
     account_id: &'a str,

src/lib.rs

@@ -7,6 +7,8 @@
 )]
 #![warn(clippy::pedantic)]
 #![allow(clippy::missing_errors_doc)]
+#![feature(into_future)]
+#![feature(type_alias_impl_trait)]
 
 //! A Monzo client in pure rust.
 //!