1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44

//! Stores the wrapper functions that can be called from either native or wasm code

use reqwest::{Error, RequestBuilder, Response};

/// Performs a HTTP requests and calls the given callback when done. NB: Needs to use a callback to prevent blocking on the thread that initiates the fetch.
/// Note: Instead of calling get like in the example you can use post, put, etc. (See [reqwest::Client]).
///
/// # Tokio example
/// ```rust
///# use reqwest::{Client, Error, Response};
///# use futures::channel::oneshot;
///# use reqwest_cross::fetch;
///
///# #[cfg(all(not(target_arch = "wasm32"),feature = "native-tokio"))]
///# #[tokio::main(flavor = "current_thread")]
///# async fn main() -> Result<(), Box<dyn std::error::Error>> {
///  let request = Client::new().get("http://httpbin.org/get");
///  let (tx, rx) = oneshot::channel();
///
///  fetch(request, move |result: Result<Response, Error>| {
///      tx.send(result.expect("Expecting Response not Error").status())
///                .expect("Receiver should still be available");
///  });
///
///  let status = rx.await?; //In actual use case code to prevent blocking use try_recv instead
///  assert_eq!(status, 200);
///# Ok(())
///# }
///
///# #[cfg(target_arch = "wasm32")]
///# fn main(){}
/// ```
pub fn fetch(
    request: RequestBuilder,
    on_done: impl 'static + Send + FnOnce(Result<Response, Error>),
) {
    #[cfg(not(target_arch = "wasm32"))]
    crate::native::fetch(request, Box::new(on_done));

    #[cfg(target_arch = "wasm32")]
    crate::wasm::fetch(request, Box::new(on_done));
}

// TODO 2: Add method to make a call in a blocking fashion (useful for testing)