pub struct SendRequest<B> { /* private fields */ }Expand description
The sender side of an established connection.
Implementations
sourceimpl<B> SendRequest<B>
impl<B> SendRequest<B>
sourcepub fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<()>>
pub fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<()>>
Polls to determine whether this sender can be used yet for a request.
If the associated connection is closed, this returns an Error.
sourceimpl<B> SendRequest<B>where
B: HttpBody + 'static,
impl<B> SendRequest<B>where
B: HttpBody + 'static,
sourcepub fn send_request(&mut self, req: Request<B>) -> ResponseFutureⓘNotable traits for ResponseFutureimpl Future for ResponseFuture type Output = Result<Response<Body>>;
pub fn send_request(&mut self, req: Request<B>) -> ResponseFutureⓘNotable traits for ResponseFutureimpl Future for ResponseFuture type Output = Result<Response<Body>>;
Sends a Request on the associated connection.
Returns a future that if successful, yields the Response.
Note
There are some key differences in what automatic things the Client
does for you that will not be done here:
Clientrequires absolute-formUris, since the scheme and authority are needed to connect. They aren’t required here.- Since the
Clientrequires absolute-formUris, it can add theHostheader based on it. You must add aHostheader yourself before calling this method. - Since absolute-form
Uris are not required, if received, they will be serialized as-is.
Example
use hyper::Request;
// build a Request
let req = Request::builder()
.uri("/foo/bar")
.header(HOST, "hyper.rs")
.body(Body::empty())
.unwrap();
// send it and await a Response
let res = tx.send_request(req).await?;
// assert the Response
assert!(res.status().is_success());Trait Implementations
sourceimpl<B> Debug for SendRequest<B>
impl<B> Debug for SendRequest<B>
sourceimpl<B> Service<Request<B>> for SendRequest<B>where
B: HttpBody + 'static,
impl<B> Service<Request<B>> for SendRequest<B>where
B: HttpBody + 'static,
type Future = ResponseFuture
type Future = ResponseFuture
The future response value.
sourcefn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>
fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>
Returns
Poll::Ready(Ok(())) when the service is able to process requests. Read moreAuto Trait Implementations
impl<B> !RefUnwindSafe for SendRequest<B>
impl<B> Send for SendRequest<B>where
B: Send,
impl<B> Sync for SendRequest<B>where
B: Send,
impl<B> Unpin for SendRequest<B>
impl<B> !UnwindSafe for SendRequest<B>
Blanket Implementations
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
const: unstablefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more