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
68
extern crate futures;
use futures::{Stream, Future, Poll};
pub struct MarkedFuture<I,E,O,F>
where F : Future<Item=I, Error=E>
{
f: F,
o: O,
}
pub fn mark_future<I,E,O,F>(f: F, o: O)
-> MarkedFuture<I,E,O,F>
where F : Future<Item=I, Error=E>
{
MarkedFuture{
f,
o,
}
}
impl<I,E,O,F> Future for MarkedFuture<I,E,O,F>
where F : Future<Item=I, Error=E>
{
type Item = I;
type Error = E;
fn poll(&mut self) -> Poll<I,E> {
let _ = &self.o;
self.f.poll()
}
}
pub struct MarkedStream<I,E,O,F>
where F : Stream<Item=I, Error=E>
{
f: F,
o: O,
}
pub fn mark_stream<I,E,O,F>(f: F, o: O)
-> MarkedStream<I,E,O,F>
where F : Stream<Item=I, Error=E>
{
MarkedStream{
f,
o,
}
}
impl<I,E,O,F> Stream for MarkedStream<I,E,O,F>
where F : Stream<Item=I, Error=E>
{
type Item = I;
type Error = E;
fn poll(&mut self) -> Poll<Option<I>,E> {
let _ = &self.o;
self.f.poll()
}
}
#[test]
pub fn bla() {
let blurp = futures::future::ok(1) as futures::future::FutureResult<_,()>;
let mut blurp = mark_future(blurp, 3);
assert_eq!(blurp.poll(), Ok(futures::Async::Ready(1)));
}