[−][src]Trait hreq::BlockExt

pub trait BlockExt {
    fn block(self) -> Self::Output
    where
        Self: Future;
}

Blocks on a Future using the hreq configured AsyncRuntime.

hreq is an async lib but every call can be turned sync by using .block() in the same positions you would use .await. Depending on the runtime, this might use the blocked thread to drive the entire async operation.

This feature needs support by the current AsyncRuntime. The only runtime where this doesn't work is TokioShared (see technical notes below).

Single thread default

We want hreq to use a minimal amount of resources. By default hreq uses a tokio runtime using the rt-core feature which is a single threaded executor. The user can configure hreq into a runtime with thread pools and work stealing.

The default runtime configuration is TokioDefault which supports .block().

Usage

To synchronously make a request put .block() where .await usually goes.

use hreq::prelude::*;

let res = Request::get("https://www.google.com")
    .call().block();

Another way is to group a series of async actions with .await and then run the entire thing with one .block().

use hreq::prelude::*;

let body_str = async {
    let res = Request::get("https://www.google.com")
        .call().await?;

    let mut body = res.into_body();
    body.read_to_string().await
}.block().unwrap();

assert_eq!(&body_str.as_bytes()[0..15], b"<!doctype html>");

Technical note

For tokio we need a direct reference to the Runtime to reach the block_on function, something we don't get when talking to a shared runtime via a Handle.

This is not a problem with async-std where there is only one shared runtime and we can always use the block_on function.

Required methods

fn block(self) -> Self::Output where
    Self: Future, 

Loading content...

Implementors

impl<F: Future> BlockExt for F[src]

Loading content...