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
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
use std::{
io,
sync::atomic::{AtomicBool, Ordering},
};
pub struct Iter<'a, I, EFN> {
pub inner: I,
make_err: Option<EFN>,
should_interrupt: &'a AtomicBool,
}
impl<'a, I, EFN, E> Iter<'a, I, EFN>
where
I: Iterator,
EFN: FnOnce() -> E,
{
pub fn new(inner: I, make_err: EFN, should_interrupt: &'a AtomicBool) -> Self {
Iter {
inner,
make_err: Some(make_err),
should_interrupt,
}
}
}
impl<'a, I, EFN, E> Iterator for Iter<'a, I, EFN>
where
I: Iterator,
EFN: FnOnce() -> E,
{
type Item = Result<I::Item, E>;
fn next(&mut self) -> Option<Self::Item> {
self.make_err.as_ref()?;
if self.should_interrupt.load(Ordering::Relaxed) {
return Some(Err(self.make_err.take().expect("no bug")()));
}
match self.inner.next() {
Some(next) => Some(Ok(next)),
None => {
self.make_err = None;
None
}
}
}
}
pub struct Read<'a, R> {
pub inner: R,
pub should_interrupt: &'a AtomicBool,
}
impl<'a, R> io::Read for Read<'a, R>
where
R: io::Read,
{
fn read(&mut self, buf: &mut [u8]) -> io::Result<usize> {
if self.should_interrupt.load(Ordering::Relaxed) {
return Err(io::ErrorKind::Interrupted.into());
}
self.inner.read(buf)
}
}
impl<'a, R> io::BufRead for Read<'a, R>
where
R: io::BufRead,
{
fn fill_buf(&mut self) -> io::Result<&[u8]> {
self.inner.fill_buf()
}
fn consume(&mut self, amt: usize) {
self.inner.consume(amt)
}
}