Add Client and Server traits

Author: yoshuawuyts

Cargo.toml

@@ -13,6 +13,7 @@ edition = "2018"
 
 [features]
 default = []
+unstable = []
 hyperium_http = ["http"]
 
 [dependencies]

src/client.rs

@@ -0,0 +1,13 @@
+use std::fmt::Debug;
+use std::future::Future;
+use std::pin::Pin;
+
+use crate::{Request, Response, Result};
+
+type BoxFuture<'a, T> = Pin<Box<dyn Future<Output = T> + 'a + Send>>;
+
+/// An HTTP client.
+pub trait Client: Debug + Unpin + Send + Sync + Clone + 'static {
+    /// Send an HTTP request from the client.
+    fn send_req(&self, req: Request) -> BoxFuture<'static, Result<Response>>;
+}

src/lib.rs

@@ -115,21 +115,25 @@ pub mod headers;
 pub mod mime;
 
 mod body;
+mod client;
 mod error;
 mod macros;
 mod method;
 mod request;
 mod response;
+mod server;
 mod status;
 mod status_code;
 mod type_map;
 mod version;
 
 pub use body::Body;
+pub use client::Client;
 pub use error::{Error, Result};
 pub use method::Method;
 pub use request::Request;
 pub use response::Response;
+pub use server::Server;
 pub use status::Status;
 pub use status_code::StatusCode;
 pub use version::Version;

src/request.rs

@@ -2,6 +2,7 @@ use async_std::io::{self, BufRead, Read};
 use async_std::sync;
 
 use std::convert::TryInto;
+use std::future::Future;
 use std::mem;
 use std::pin::Pin;
 use std::task::{Context, Poll};
@@ -13,6 +14,9 @@ use crate::mime::Mime;
 use crate::trailers::{Trailers, TrailersSender};
 use crate::Cookie;
 use crate::{Body, Method, TypeMap, Url, Version};
+use crate::{Client, Error, Response, Server};
+
+type BoxFuture<'a, T> = Pin<Box<dyn Future<Output = T> + 'a + Send>>;
 
 pin_project_lite::pin_project! {
     /// An HTTP request.
@@ -439,6 +443,22 @@ impl Request {
         self.receiver.recv().await
     }
 
+    /// Send a request directly to a server.
+    ///
+    /// This is useful for sending a request to a server without needing to
+    /// make any further HTTP requests. Examples include: HTTP endpoints in
+    /// frameworks, or testing logic for requests.
+    pub fn send_to<S: Server>(self, server: &S) -> BoxFuture<'static, Result<Response, Error>> {
+        server.recv_req(self)
+    }
+
+    /// Send a request through a client.
+    ///
+    /// This will most likely create an HTTP request over the network.
+    pub fn send_from<C: Client>(self, client: &C) -> BoxFuture<'static, Result<Response, Error>> {
+        client.send_req(self)
+    }
+
     /// An iterator visiting all header pairs in arbitrary order.
     pub fn iter<'a>(&'a self) -> headers::Iter<'a> {
         self.headers.iter()

src/server.rs

@@ -0,0 +1,13 @@
+use std::fmt::Debug;
+use std::future::Future;
+use std::pin::Pin;
+
+use crate::{Request, Response, Result};
+
+type BoxFuture<'a, T> = Pin<Box<dyn Future<Output = T> + 'a + Send>>;
+
+/// An HTTP server.
+pub trait Server: Debug + Unpin + Send + Sync + Clone + 'static {
+    /// Receive an HTTP request on the server.
+    fn recv_req(&self, req: Request) -> BoxFuture<'static, Result<Response>>;
+}