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
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
extern crate tetsy_fetch;
extern crate hyper;
extern crate futures;
use hyper::{StatusCode, Body};
use futures::{future, future::FutureResult};
use tetsy_fetch::{Fetch, Url, Request};
#[derive(Clone, Default)]
pub struct FakeFetch<T> where T: Clone + Send + Sync {
val: Option<T>,
}
impl<T> FakeFetch<T> where T: Clone + Send + Sync {
pub fn new(t: Option<T>) -> Self {
FakeFetch { val : t }
}
}
impl<T: 'static> Fetch for FakeFetch<T> where T: Clone + Send+ Sync {
type Result = FutureResult<tetsy_fetch::Response, tetsy_fetch::Error>;
fn fetch(&self, request: Request, abort: tetsy_fetch::Abort) -> Self::Result {
let u = request.url().clone();
future::ok(if self.val.is_some() {
let r = hyper::Response::new("Some content".into());
tetsy_fetch::client::Response::new(u, r, abort)
} else {
let r = hyper::Response::builder()
.status(StatusCode::NOT_FOUND)
.body(Body::empty()).expect("Nothing to parse, can not fail; qed");
tetsy_fetch::client::Response::new(u, r, abort)
})
}
fn get(&self, url: &str, abort: tetsy_fetch::Abort) -> Self::Result {
let url: Url = match url.parse() {
Ok(u) => u,
Err(e) => return future::err(e.into())
};
self.fetch(Request::get(url), abort)
}
fn post(&self, url: &str, abort: tetsy_fetch::Abort) -> Self::Result {
let url: Url = match url.parse() {
Ok(u) => u,
Err(e) => return future::err(e.into())
};
self.fetch(Request::post(url), abort)
}
}