Files
aho_corasick
ansi_term
arrayvec
atty
backtrace
backtrace_sys
base64
bincode
bitflags
byteorder
bytes
c2_chacha
capnp
capnp_futures
capnp_rpc
cfg_if
chrono
format
naive
offset
clap
app
args
completions
crossbeam_deque
crossbeam_epoch
crossbeam_queue
crossbeam_utils
ctrlc
daemon
failure
failure_derive
flexi_logger
fnv
futures
future
sink
stream
and_then.rsbuffer_unordered.rsbuffered.rscatch_unwind.rschain.rschannel.rschunks.rscollect.rsconcat.rsempty.rsfilter.rsfilter_map.rsflatten.rsfold.rsfor_each.rsforward.rsfrom_err.rsfuse.rsfuture.rsfutures_ordered.rsfutures_unordered.rsinspect.rsinspect_err.rsiter.rsiter_ok.rsiter_result.rsmap.rsmap_err.rsmerge.rsmod.rsonce.rsor_else.rspeek.rspoll_fn.rsrepeat.rsselect.rsskip.rsskip_while.rssplit.rstake.rstake_while.rsthen.rsunfold.rswait.rszip.rs
sync
task_impl
unsync
getrandom
glob
hid_io
api
device
module
protocol
hidapi
install_service
iovec
lazy_static
libc
unix
lock_api
log
memchr
memoffset
mio
deprecated
net
sys
mio_uds
nanoid
net2
nix
net
sys
nodrop
num_cpus
num_integer
num_traits
open
parking_lot
parking_lot_core
pem
ppv_lite86
proc_macro2
quote
rand
distributions
weighted
rngs
seq
rand_chacha
rand_core
rand_hc
rand_isaac
rand_jitter
rand_os
rand_pcg
rand_xorshift
rcgen
regex
regex_syntax
ast
hir
unicode_tables
remove_dir_all
ring
aead
arithmetic
digest
ec
curve25519
suite_b
io
polyfill
rsa
rustc_demangle
rustls
client
msgs
server
scoped_tls
scopeguard
sct
serde
de
private
ser
slab
smallvec
spin
stream_cancel
strsim
syn
attr.rsbigint.rsbuffer.rscustom_keyword.rscustom_punctuation.rsdata.rsderive.rsdiscouraged.rserror.rsexport.rsexpr.rsext.rsfile.rsgenerics.rsgroup.rsident.rsitem.rslib.rslifetime.rslit.rslookahead.rsmac.rsmacros.rsop.rsparse.rsparse_macro_input.rsparse_quote.rspat.rspath.rsprint.rspunctuated.rssealed.rsspan.rsspanned.rsstmt.rsthread.rstoken.rstt.rsty.rs
synstructure
tempfile
textwrap
thread_local
time
tokio
codec
executor
reactor
runtime
util
tokio_codec
tokio_core
io
net
reactor
tokio_current_thread
tokio_executor
tokio_fs
tokio_io
_tokio_codec
codec
io
tokio_reactor
tokio_rustls
tokio_sync
tokio_tcp
tokio_threadpool
park
pool
task
worker
tokio_timer
clock
timer
wheel
tokio_udp
tokio_uds
unicode_width
unicode_xid
untrusted
vec_map
void
webpki
windows_service
x11
xcb
xkbcommon
yasna
>
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
use core::marker::PhantomData; use {Sink, Poll, StartSend}; /// A sink combinator to change the error type of a sink. /// /// This is created by the `Sink::from_err` method. #[derive(Clone, Debug)] #[must_use = "futures do nothing unless polled"] pub struct SinkFromErr<S, E> { sink: S, f: PhantomData<E> } pub fn new<S, E>(sink: S) -> SinkFromErr<S, E> where S: Sink { SinkFromErr { sink: sink, f: PhantomData } } impl<S, E> SinkFromErr<S, E> { /// Get a shared reference to the inner sink. pub fn get_ref(&self) -> &S { &self.sink } /// Get a mutable reference to the inner sink. pub fn get_mut(&mut self) -> &mut S { &mut self.sink } /// Consumes this combinator, returning the underlying sink. /// /// Note that this may discard intermediate state of this combinator, so /// care should be taken to avoid losing resources when this is called. pub fn into_inner(self) -> S { self.sink } } impl<S, E> Sink for SinkFromErr<S, E> where S: Sink, E: From<S::SinkError> { type SinkItem = S::SinkItem; type SinkError = E; fn start_send(&mut self, item: Self::SinkItem) -> StartSend<Self::SinkItem, Self::SinkError> { self.sink.start_send(item).map_err(|e| e.into()) } fn poll_complete(&mut self) -> Poll<(), Self::SinkError> { self.sink.poll_complete().map_err(|e| e.into()) } fn close(&mut self) -> Poll<(), Self::SinkError> { self.sink.close().map_err(|e| e.into()) } } impl<S: ::stream::Stream, E> ::stream::Stream for SinkFromErr<S, E> { type Item = S::Item; type Error = S::Error; fn poll(&mut self) -> Poll<Option<S::Item>, S::Error> { self.sink.poll() } }