instant-labs
/
instant-acme
mirror of https://github.com/instant-labs/instant-acme.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Replace `ResponseFuture` with `Box<dyn>` (#28)

This commit is contained in:
Daniel Bloom 2023-06-14 04:21:31 -07:00 committed by GitHub
parent a5ff6ff26e
commit 382aada615
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 16 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
src/lib.rs
View File

@ -5,13 +5,14 @@
use std::borrow::Cow;
use std::fmt;
use std::future::Future;
use std::pin::Pin;
use std::sync::Arc;
use base64::prelude::{Engine, BASE64_URL_SAFE_NO_PAD};
use hyper::client::connect::Connect;
#[cfg(feature = "hyper-rustls")]
use hyper::client::HttpConnector;
use hyper::client::ResponseFuture;
use hyper::header::{CONTENT_TYPE, LOCATION};
use hyper::{Body, Method, Request, Response};
use ring::digest::{digest, SHA256};
@ -599,8 +600,11 @@ struct DefaultClient(hyper::Client<hyper_rustls::HttpsConnector<HttpConnector>>)
#[cfg(feature = "hyper-rustls")]
impl HttpClient for DefaultClient {
fn request(&self, req: Request<Body>) -> ResponseFuture {
self.0.request(req)
fn request(
&self,
req: Request<Body>,
) -> Pin<Box<dyn Future<Output = hyper::Result<Response<Body>>>>> {
Box::pin(self.0.request(req))
}
}
@ -623,15 +627,21 @@ impl Default for DefaultClient {
/// A HTTP client based on [`hyper::Client`]
pub trait HttpClient: Send + Sync + 'static {
/// Send the given request and return the response
fn request(&self, req: Request<Body>) -> ResponseFuture;
fn request(
&self,
req: Request<Body>,
) -> Pin<Box<dyn Future<Output = hyper::Result<Response<Body>>>>>;
}
impl<C> HttpClient for hyper::Client<C>
where
C: Connect + Clone + Send + Sync + 'static,
{
fn request(&self, req: Request<Body>) -> ResponseFuture {
<hyper::Client<C>>::request(self, req)
fn request(
&self,
req: Request<Body>,
) -> Pin<Box<dyn Future<Output = hyper::Result<Response<Body>>>>> {
Box::pin(<hyper::Client<C>>::request(self, req))
}
}