Files
adler32
aho_corasick
ansi_term
atty
backtrace
backtrace_sys
base64
base_x
bitflags
block_buffer
block_padding
bstr
byte_tools
byteorder
bytes
cargo_metadata
cargo_web
build.rschrome_devtools.rscmd_build.rscmd_deploy.rscmd_prepare_emscripten.rscmd_start.rscmd_test.rsconfig.rsdeployment.rsemscripten.rserror.rshttp_utils.rslib.rspackage.rsproject_dirs.rstest_chromium.rsutils.rswasm.rswasm_context.rswasm_export_main.rswasm_export_table.rswasm_gc.rswasm_hook_grow.rswasm_inline_js.rswasm_intrinsics.rswasm_js_export.rswasm_js_snippet.rswasm_runtime.rs
cfg_if
clap
app
args
completions
cookie
cookie_store
crc32fast
crossbeam_channel
crossbeam_deque
crossbeam_epoch
crossbeam_queue
crossbeam_utils
digest
directories
dirs_sys
dtoa
either
embed_wasm
embed_wasm_build
encoding_rs
env_logger
filter
fmt
error_chain
failure
failure_derive
fake_simd
filetime
flate2
deflate
ffi
gz
zlib
fnv
foreign_types
foreign_types_shared
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_channel
futures_core
futures_cpupool
futures_sink
futures_task
futures_util
future
future
try_future
stream
stream
try_stream
task
generic_array
getrandom
globset
h2
codec
frame
hpack
proto
handlebars
directives
helpers
headers
common
accept_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_length.rscontent_location.rscontent_range.rscontent_type.rscookie.rsdate.rsetag.rsexpect.rsexpires.rshost.rsif_match.rsif_modified_since.rsif_none_match.rsif_range.rsif_unmodified_since.rslast_modified.rslocation.rsmod.rsorigin.rspragma.rsproxy_authorization.rsrange.rsreferer.rsreferrer_policy.rsretry_after.rssec_websocket_accept.rssec_websocket_key.rssec_websocket_version.rsserver.rsset_cookie.rsstrict_transport_security.rste.rstransfer_encoding.rsupgrade.rsuser_agent.rsvary.rs
util
headers_core
heck
http
http_body
httparse
humantime
hyper
body
client
common
proto
server
service
hyper_tls
idna
ignore
indexmap
inotify
inotify_sys
iovec
itoa
language_tags
lazy_static
lazycell
libc
unix
libflate
deflate
lz77
non_blocking
lock_api
log
maplit
matches
maybe_uninit
memchr
memmap
memoffset
mime
mime_guess
miniz_oxide
mio
deprecated
net
sys
mio_extras
mio_uds
native_tls
net2
notify
num_cpus
opaque_debug
open
openssl
openssl_probe
openssl_sys
parity_wasm
builder
elements
parking_lot
parking_lot_core
pbr
percent_encoding
pest
iterators
unicode
pest_derive
pest_generator
pest_meta
phf
phf_codegen
phf_generator
phf_shared
pin_project
pin_project_internal
pin_project_lite
pin_utils
ppv_lite86
proc_macro2
publicsuffix
quick_error
quote
rand
distributions
weighted
rngs
seq
rand_chacha
rand_core
rand_hc
rand_isaac
rand_jitter
rand_os
rand_pcg
rand_xorshift
regex
regex_syntax
ast
hir
unicode_tables
remove_dir_all
reqwest
rle_decode_fast
rustc_demangle
ryu
safemem
same_file
scoped_tls
scopeguard
semver
semver_parser
serde
de
private
ser
serde_derive
serde_json
serde_urlencoded
sha1
sha2
siphasher
slab
smallvec
string
strsim
structopt
structopt_derive
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.rsverbatim.rs
synstructure
take_mut
tar
tempfile
termcolor
textwrap
thread_local
time
tokio
codec
executor
reactor
runtime
util
tokio_buf
tokio_codec
tokio_core
io
net
reactor
tokio_current_thread
tokio_executor
tokio_fs
tokio_io
_tokio_codec
codec
io
tokio_reactor
tokio_sync
tokio_tcp
tokio_threadpool
blocking
park
pool
task
worker
tokio_timer
clock
timer
wheel
tokio_tls
tokio_udp
tokio_uds
tokio_util
codec
toml
tower_service
traitobject
try_from
try_lock
typeable
typenum
ucd_trie
unicase
unicode_bidi
unicode_categories
unicode_normalization
unicode_segmentation
unicode_width
unicode_xid
url
uuid
vec_map
walkdir
want
websocket
client
codec
header
server
ws
xattr
>
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
use std::io; use std::mem; use futures::{Future, Poll}; use AsyncRead; /// A future which can be used to easily read exactly enough bytes to fill /// a buffer. /// /// Created by the [`read_exact`] function. /// /// [`read_exact`]: fn.read_exact.html #[derive(Debug)] pub struct ReadExact<A, T> { state: State<A, T>, } #[derive(Debug)] enum State<A, T> { Reading { a: A, buf: T, pos: usize }, Empty, } /// Creates a future which will read exactly enough bytes to fill `buf`, /// returning an error if EOF is hit sooner. /// /// The returned future will resolve to both the I/O stream as well as the /// buffer once the read operation is completed. /// /// In the case of an error the buffer and the object will be discarded, with /// the error yielded. In the case of success the object will be destroyed and /// the buffer will be returned, with all data read from the stream appended to /// the buffer. pub fn read_exact<A, T>(a: A, buf: T) -> ReadExact<A, T> where A: AsyncRead, T: AsMut<[u8]>, { ReadExact { state: State::Reading { a: a, buf: buf, pos: 0, }, } } fn eof() -> io::Error { io::Error::new(io::ErrorKind::UnexpectedEof, "early eof") } impl<A, T> Future for ReadExact<A, T> where A: AsyncRead, T: AsMut<[u8]>, { type Item = (A, T); type Error = io::Error; fn poll(&mut self) -> Poll<(A, T), io::Error> { match self.state { State::Reading { ref mut a, ref mut buf, ref mut pos, } => { let buf = buf.as_mut(); while *pos < buf.len() { let n = try_ready!(a.poll_read(&mut buf[*pos..])); *pos += n; if n == 0 { return Err(eof()); } } } State::Empty => panic!("poll a ReadExact after it's done"), } match mem::replace(&mut self.state, State::Empty) { State::Reading { a, buf, .. } => Ok((a, buf).into()), State::Empty => panic!(), } } }