Files
adler32
ahash
aho_corasick
ansi_term
antidote
anyhow
arc_swap
arrayvec
async_speed_limit
async_stream
async_stream_impl
async_trait
atty
aws
backtrace
backtrace_sys
backup
base64
batch_system
bitfield
bitflags
block_buffer
boolinator
bstr
byteset
search
unicode
byteorder
bytes
buf
fmt
bzip2_sys
cargo_metadata
cdc
cfg_if
chrono
format
naive
offset
chrono_tz
clap
app
args
completions
cloud
codec
collections
concurrency_manager
configuration
configuration_derive
const_fn
const_random
const_random_macro
coprocessor_plugin_api
cpuid_bool
crc32fast
crc64fast
crossbeam
crossbeam_channel
crossbeam_deque
crossbeam_epoch
crossbeam_queue
crossbeam_skiplist
crossbeam_utils
crypto_mac
darling
darling_core
ast
codegen
error
options
usage
util
darling_macro
dashmap
debugid
derive_more
digest
dirs
dirs_sys
doc_comment
dtoa
either
encoding_rs
encryption
encryption_export
engine_panic
engine_rocks
cf_names.rscf_options.rscompact.rscompact_listener.rscompat.rsconfig.rsdb_options.rsdb_vector.rsencryption.rsengine.rsengine_iterator.rsevent_listener.rsfile_system.rsimport.rslib.rslogger.rsmisc.rsmvcc_properties.rsoptions.rsperf_context.rsperf_context_impl.rsperf_context_metrics.rsproperties.rsraft_engine.rsrange_properties.rsraw.rsraw_util.rsrocks_metrics.rsrocks_metrics_defs.rssnapshot.rssst.rssst_partitioner.rstable_properties.rsttl_properties.rsutil.rswrite_batch.rs
engine_test
engine_traits
cf_defs.rscf_names.rscf_options.rscompact.rscompaction_job.rsconfig.rsdb_options.rsdb_vector.rsencryption.rsengine.rsengines.rserrors.rsfile_system.rsimport.rsiterable.rslib.rsmisc.rsmutable.rsmvcc_properties.rsoptions.rspeekable.rsperf_context.rsproperties.rsraft_engine.rsrange.rsrange_properties.rssnapshot.rssst.rssst_partitioner.rstable_properties.rsttl_properties.rsutil.rswrite_batch.rs
engine_traits_tests
error_code
error_code_gen
example_plugin
external_storage
external_storage_export
fail
failure
failure_derive
farmhash
file_system
filetime
flate2
deflate
gz
zlib
fnv
foreign_types
foreign_types_shared
fs2
futures
futures_channel
futures_core
futures_executor
futures_io
futures_macro
futures_sink
futures_task
futures_timer
futures_util
async_await
compat
future
future
try_future
io
allow_std.rsbuf_reader.rsbuf_writer.rschain.rsclose.rscopy.rscopy_buf.rscursor.rsempty.rsfill_buf.rsflush.rsinto_sink.rslines.rsmod.rsread.rsread_exact.rsread_line.rsread_to_end.rsread_to_string.rsread_until.rsread_vectored.rsrepeat.rsseek.rssink.rssplit.rstake.rswindow.rswrite.rswrite_all.rswrite_vectored.rs
lock
sink
stream
futures_unordered
stream
buffer_unordered.rsbuffered.rscatch_unwind.rschain.rschunks.rscollect.rsconcat.rscycle.rsenumerate.rsfilter.rsfilter_map.rsflatten.rsfold.rsfor_each.rsfor_each_concurrent.rsforward.rsfuse.rsinto_future.rsmap.rsmod.rsnext.rspeek.rsready_chunks.rsscan.rsselect_next_some.rsskip.rsskip_while.rssplit.rstake.rstake_until.rstake_while.rsthen.rsunzip.rszip.rs
try_stream
task
fuzz
fxhash
gcp
generic_array
getrandom
getset
grpcio
grpcio_health
grpcio_sys
h2
codec
frame
hpack
proto
heck
hex
hmac
http
http_body
httparse
httpdate
hyper
body
client
common
proto
server
service
hyper_openssl
hyper_tls
ident_case
idna
indexmap
inferno
collapse
differential
flamegraph
inotify
inotify_sys
instant
into_other
iovec
ipnet
ipnetwork
itertools
adaptors
combinations.rscombinations_with_replacement.rsconcat_impl.rscons_tuples_impl.rsdiff.rseither_or_both.rsexactly_one_err.rsformat.rsfree.rsgroup_map.rsgroupbylazy.rsimpl_macros.rsintersperse.rskmerge_impl.rslazy_buffer.rslib.rsmerge_join.rsminmax.rsmultipeek_impl.rspad_tail.rspeeking_take_while.rspermutations.rsprocess_results_impl.rsput_back_n_impl.rsrciter_impl.rsrepeatn.rssize_hint.rssources.rstee.rstuple_impl.rsunique_impl.rswith_position.rszip_eq_impl.rszip_longest.rsziptuple.rs
itoa
keys
kvproto
lazy_static
lazycell
libc
unix
libflate
deflate
non_blocking
libflate_lz77
libloading
librocksdb_sys
libtitan_sys
libz_sys
linked_hash_map
linked_hash_set
lock_api
log
log_wrappers
lz4_sys
match_template
matches
md5
memchr
memmap
memoffset
memory_trace_macros
mime
mime_guess
mio
deprecated
net
sys
mio_extras
mio_uds
more_asserts
murmur3
native_tls
net2
nix
net
sys
nodrop
nom
bits
branch
bytes
character
combinator
multi
number
sequence
notify
num
num_complex
num_cpus
num_derive
num_format
impls
num_integer
num_iter
num_rational
num_traits
once_cell
opaque_debug
openssl
openssl_probe
openssl_sys
ordered_float
panic_hook
parking_lot
parking_lot_core
paste
paste_impl
pd_client
percent_encoding
pest
iterators
unicode
pin_project
pin_project_lite
pin_utils
pnet_base
pnet_datalink
pnet_sys
pprof
ppv_lite86
proc_macro2
proc_macro_error
proc_macro_error_attr
proc_macro_hack
proc_macro_nested
procfs
procinfo
net
pid
sys
profiler
prometheus
prometheus_static_metric
promptly
prost
prost_derive
protobuf
reflect
well_known_types
quick_xml
quote
raft
raft_engine
raft_log_engine
raft_proto
raftstore
coprocessor
store
fsm
snap
worker
rand
distributions
rngs
seq
rand_chacha
rand_core
rand_isaac
rayon
collections
compile_fail
iter
chain.rschunks.rscloned.rscopied.rsempty.rsenumerate.rsextend.rsfilter.rsfilter_map.rsfind.rsflat_map.rsflat_map_iter.rsflatten.rsflatten_iter.rsfold.rsfor_each.rsfrom_par_iter.rsinspect.rsinterleave.rsinterleave_shortest.rsintersperse.rslen.rsmap.rsmap_with.rsmod.rsmultizip.rsnoop.rsonce.rspanic_fuse.rspar_bridge.rspositions.rsproduct.rsreduce.rsrepeat.rsrev.rsskip.rssplitter.rsstep_by.rssum.rstake.rstry_fold.rstry_reduce.rstry_reduce_with.rsunzip.rsupdate.rswhile_some.rszip.rszip_eq.rs
slice
rayon_core
compile_fail
join
scope
sleep
spawn
thread_pool
regex
regex_automata
regex_syntax
ast
hir
unicode_tables
remove_dir_all
reqwest
async_impl
blocking
resolved_ts
rev_lines
rgb
ring
aead
gcm
arithmetic
digest
ec
curve25519
suite_b
io
rsa
rle_decode_fast
rocksdb
compaction_filter.rscomparator.rsencryption.rsevent_listener.rsfile_system.rslib.rslogger.rsmerge_operator.rsmetadata.rsperf_context.rsrocksdb.rsrocksdb_options.rsslice_transform.rssst_partitioner.rstable_filter.rstable_properties.rstable_properties_collector.rstable_properties_collector_factory.rstable_properties_rc.rstable_properties_rc_handles.rstitan.rswrite_batch.rs
rusoto_core
rusoto_credential
rusoto_kms
custom
rusoto_s3
rusoto_signature
rusoto_sts
rustc_demangle
rustyline
ryu
safemem
same_file
scopeguard
security
semver
semver_parser
serde
de
private
ser
serde_derive
serde_ignored
serde_json
serde_urlencoded
serde_with
duplicate_key_impls
serde_with_macros
server
sha2
shlex
signal
signal_hook_registry
slab
slog
slog_async
slog_derive
slog_global
slog_json
slog_term
smallvec
snappy_sys
socket2
spin
sst_importer
stable_deref_trait
standback
static_assertions
str_stack
strsim
structopt
structopt_derive
strum
strum_macros
helpers
macros
subtle
symbolic_common
symbolic_demangle
syn
attr.rsawait.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.rsreserved.rssealed.rsspan.rsspanned.rsstmt.rsthread.rstoken.rstt.rsty.rsverbatim.rswhitespace.rs
syn_mid
synstructure
sysinfo
take_mut
tame_gcs
tame_oauth
tempfile
term
terminfo
test_backup
test_coprocessor
test_pd
test_raftstore
test_sst_importer
test_storage
test_util
textwrap
thiserror
thiserror_impl
thread_local
tidb_query_aggr
tidb_query_codegen
tidb_query_common
tidb_query_datatype
builder
codec
batch
chunk
collation
data_type
mysql
json
time
row
def
expr
tidb_query_executors
tidb_query_expr
tikv
coprocessor
dag
interceptors
statistics
coprocessor_v2
import
server
gc_worker
load_statistics
lock_manager
service
status_server
ttl
storage
kv
mvcc
raw
txn
actions
commands
acquire_pessimistic_lock.rsatomic_store.rscheck_secondary_locks.rscheck_txn_status.rscleanup.rscommit.rscompare_and_swap.rsmacros.rsmod.rsmvcc_by_key.rsmvcc_by_start_ts.rspause.rspessimistic_rollback.rsprewrite.rsresolve_lock.rsresolve_lock_lite.rsresolve_lock_readphase.rsrollback.rstxn_heart_beat.rs
tikv_alloc
tikv_ctl
tikv_jemalloc_ctl
tikv_jemalloc_sys
tikv_jemallocator
tikv_kv
tikv_server
tikv_util
codec
logger
metrics
mpsc
sys
worker
yatp_pool
time
time_macros
time_macros_impl
tipb
tipb_helper
tokio
fs
future
io
driver
util
async_buf_read_ext.rsasync_read_ext.rsasync_seek_ext.rsasync_write_ext.rsbuf_reader.rsbuf_stream.rsbuf_writer.rschain.rscopy.rsempty.rsflush.rslines.rsmem.rsmod.rsread.rsread_buf.rsread_exact.rsread_int.rsread_line.rsread_to_end.rsread_to_string.rsread_until.rsreader_stream.rsrepeat.rsshutdown.rssink.rssplit.rsstream_reader.rstake.rswrite.rswrite_all.rswrite_buf.rswrite_int.rs
loom
std
macros
net
tcp
udp
unix
park
process
runtime
blocking
task
thread_pool
signal
stream
sync
task
time
util
tokio_executor
tokio_macros
tokio_openssl
tokio_timer
clock
timer
wheel
tokio_tls
tokio_util
codec
toml
tower_service
tracing
tracing_core
try_lock
twoway
twox_hash
txn_types
typenum
ucd_trie
unchecked_index
unicase
unicode_bidi
unicode_normalization
unicode_segmentation
unicode_width
unicode_xid
untrusted
url
utf8parse
uuid
vec_map
vlog
walkdir
want
xml
reader
parser
writer
yatp
pool
queue
task
zeroize
zstd_sys
>
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
//! "Diff"ing iterators for caching elements to sequential collections without requiring the new //! elements' iterator to be `Clone`. //! //! - [**Diff**](./enum.Diff.html) (produced by the [**diff_with**](./fn.diff_with.html) function) //! describes the difference between two non-`Clone` iterators `I` and `J` after breaking ASAP from //! a lock-step comparison. use free::put_back; use structs::PutBack; /// A type returned by the [`diff_with`](./fn.diff_with.html) function. /// /// `Diff` represents the way in which the elements yielded by the iterator `I` differ to some /// iterator `J`. pub enum Diff<I, J> where I: Iterator, J: Iterator { /// The index of the first non-matching element along with both iterator's remaining elements /// starting with the first mis-match. FirstMismatch(usize, PutBack<I>, PutBack<J>), /// The total number of elements that were in `J` along with the remaining elements of `I`. Shorter(usize, PutBack<I>), /// The total number of elements that were in `I` along with the remaining elements of `J`. Longer(usize, PutBack<J>), } /// Compares every element yielded by both `i` and `j` with the given function in lock-step and /// returns a `Diff` which describes how `j` differs from `i`. /// /// If the number of elements yielded by `j` is less than the number of elements yielded by `i`, /// the number of `j` elements yielded will be returned along with `i`'s remaining elements as /// `Diff::Shorter`. /// /// If the two elements of a step differ, the index of those elements along with the remaining /// elements of both `i` and `j` are returned as `Diff::FirstMismatch`. /// /// If `i` becomes exhausted before `j` becomes exhausted, the number of elements in `i` along with /// the remaining `j` elements will be returned as `Diff::Longer`. pub fn diff_with<I, J, F>(i: I, j: J, is_equal: F) -> Option<Diff<I::IntoIter, J::IntoIter>> where I: IntoIterator, J: IntoIterator, F: Fn(&I::Item, &J::Item) -> bool { let mut i = i.into_iter(); let mut j = j.into_iter(); let mut idx = 0; while let Some(i_elem) = i.next() { match j.next() { None => return Some(Diff::Shorter(idx, put_back(i).with_value(i_elem))), Some(j_elem) => if !is_equal(&i_elem, &j_elem) { let remaining_i = put_back(i).with_value(i_elem); let remaining_j = put_back(j).with_value(j_elem); return Some(Diff::FirstMismatch(idx, remaining_i, remaining_j)); }, } idx += 1; } j.next().map(|j_elem| Diff::Longer(idx, put_back(j).with_value(j_elem))) }