Files
base64
byteorder
bytes
cfg_if
crossbeam_deque
crossbeam_epoch
crossbeam_queue
crossbeam_utils
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
futures_cpupool
httparse
hyper
client
common
header
common
accept.rsaccept_charset.rsaccept_encoding.rsaccept_language.rsaccept_ranges.rsaccess_control_allow_credentials.rsaccess_control_allow_headers.rsaccess_control_allow_methods.rsaccess_control_allow_origin.rsaccess_control_expose_headers.rsaccess_control_max_age.rsaccess_control_request_headers.rsaccess_control_request_method.rsallow.rsauthorization.rscache_control.rsconnection.rscontent_disposition.rscontent_encoding.rscontent_language.rscontent_length.rscontent_location.rscontent_range.rscontent_type.rscookie.rsdate.rsetag.rsexpect.rsexpires.rsfrom.rshost.rsif_match.rsif_modified_since.rsif_none_match.rsif_range.rsif_unmodified_since.rslast_event_id.rslast_modified.rslink.rslocation.rsmod.rsorigin.rspragma.rsprefer.rspreference_applied.rsproxy_authorization.rsrange.rsreferer.rsreferrer_policy.rsretry_after.rsserver.rsset_cookie.rsstrict_transport_security.rste.rstransfer_encoding.rsupgrade.rsuser_agent.rsvary.rswarning.rs
internals
shared
proto
server
iovec
language_tags
lazy_static
libc
unix
lock_api
log
maybe_uninit
memoffset
mime
mio
deprecated
net
sys
mio_uds
net2
num_cpus
parking_lot
parking_lot_core
percent_encoding
proc_macro2
quote
rand
distributions
relay
rfsapi
safemem
scoped_tls
scopeguard
serde
de
private
ser
serde_derive
slab
smallvec
syn
attr.rsbigint.rsbuffer.rscustom_keyword.rscustom_punctuation.rsdata.rsderive.rsdiscouraged.rserror.rsexport.rsexpr.rsext.rsgenerics.rsgroup.rsident.rslib.rslifetime.rslit.rslookahead.rsmac.rsmacros.rsop.rsparse.rsparse_macro_input.rsparse_quote.rspath.rsprint.rspunctuated.rssealed.rsspan.rsspanned.rsthread.rstoken.rsty.rs
take
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_proto
simple
streaming
multiplex
pipeline
util
tokio_reactor
tokio_service
tokio_sync
tokio_tcp
tokio_threadpool
blocking
park
pool
task
worker
tokio_timer
clock
timer
wheel
tokio_udp
tokio_uds
try_lock
unicase
unicode_xid
want
>
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
use core::fmt; /// Error which occurs when popping from an empty queue. #[derive(Clone, Copy, Eq, PartialEq)] pub struct PopError; impl fmt::Debug for PopError { fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result { "PopError".fmt(f) } } impl fmt::Display for PopError { fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result { "popping from an empty queue".fmt(f) } } #[cfg(features = "std")] impl std::error::Error for PopError { fn description(&self) -> &str { "popping from an empty queue" } } /// Error which occurs when pushing into a full queue. #[derive(Clone, Copy, Eq, PartialEq)] pub struct PushError<T>(pub T); impl<T> fmt::Debug for PushError<T> { fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result { "PushError(..)".fmt(f) } } impl<T> fmt::Display for PushError<T> { fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result { "pushing into a full queue".fmt(f) } } #[cfg(features = "std")] impl<T: Send> std::error::Error for PushError<T> { fn description(&self) -> &str { "pushing into a full queue" } }