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
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
#![no_std]
#![deny(warnings)]
extern crate futures;
pub use start_send_error_sink::StartSendErrSink;
pub use poll_complete_error_sink::PollCompleteErrSink;
pub use close_error_sink::CloseErrSink;
pub mod start_send_error_sink {
use futures::{Async, Poll, Sink, StartSend};
use core::marker::PhantomData;
#[derive(Debug, PartialEq)]
pub struct Error<I>(pub I);
#[derive(Debug, Default)]
pub struct StartSendErrSink<I> {
phantom_i: PhantomData<I>,
}
impl<I> Sink for StartSendErrSink<I> {
type SinkItem = I;
type SinkError = Error<I>;
fn start_send(
&mut self,
item: Self::SinkItem,
) -> StartSend<Self::SinkItem, Self::SinkError> {
Err(Error(item))
}
fn poll_complete(&mut self) -> Poll<(), Self::SinkError> {
panic!("poll_complete is allowed to panic if start_send failed")
}
fn close(&mut self) -> Poll<(), Self::SinkError> {
Ok(Async::Ready(()))
}
}
}
pub mod poll_complete_error_sink {
use futures::{Async, AsyncSink, Poll, Sink, StartSend};
use core::marker::PhantomData;
#[derive(Debug, PartialEq)]
pub struct Error();
#[derive(Debug, Default)]
pub struct PollCompleteErrSink<I> {
phantom_i: PhantomData<I>,
}
impl<I> Sink for PollCompleteErrSink<I> {
type SinkItem = I;
type SinkError = Error;
fn start_send(
&mut self,
_item: Self::SinkItem,
) -> StartSend<Self::SinkItem, Self::SinkError> {
Ok(AsyncSink::Ready)
}
fn poll_complete(&mut self) -> Poll<(), Self::SinkError> {
Err(Error())
}
fn close(&mut self) -> Poll<(), Self::SinkError> {
Ok(Async::Ready(()))
}
}
}
pub mod close_error_sink {
use futures::{Async, AsyncSink, Poll, Sink, StartSend};
use core::marker::PhantomData;
#[derive(Debug, PartialEq)]
pub struct Error();
#[derive(Debug, Default)]
pub struct CloseErrSink<I> {
phantom_i: PhantomData<I>,
}
impl<I> Sink for CloseErrSink<I> {
type SinkItem = I;
type SinkError = Error;
fn start_send(
&mut self,
_item: Self::SinkItem,
) -> StartSend<Self::SinkItem, Self::SinkError> {
Ok(AsyncSink::Ready)
}
fn poll_complete(&mut self) -> Poll<(), Self::SinkError> {
Ok(Async::Ready(()))
}
fn close(&mut self) -> Poll<(), Self::SinkError> {
Err(Error())
}
}
}