and_then.rs - source

Files

adler32

ahash

convert.rs fallback_hash.rs folded_multiply.rs hash_map.rs hash_set.rs lib.rs random_state.rs

aho_corasick

packed

teddy

compile.rs mod.rs runtime.rs

api.rs mod.rs pattern.rs rabinkarp.rs vector.rs

ahocorasick.rs automaton.rs buffer.rs byte_frequencies.rs classes.rs dfa.rs error.rs lib.rs nfa.rs prefilter.rs state_id.rs

ansi_term

ansi.rs debug.rs difference.rs display.rs lib.rs style.rs windows.rs write.rs

antidote

anyhow

backtrace.rs chain.rs context.rs error.rs fmt.rs kind.rs lib.rs macros.rs wrapper.rs

arc_swap

access.rs as_raw.rs cache.rs compile_fail_tests.rs debt.rs gen_lock.rs lib.rs ref_cnt.rs

arrayvec

array.rs array_string.rs char.rs errors.rs lib.rs maybe_uninit_stable.rs range.rs

async_speed_limit

clock.rs io.rs lib.rs limiter.rs

async_stream

async_stream.rs lib.rs next.rs yielder.rs

async_stream_impl

async_trait

args.rs expand.rs lib.rs lifetime.rs parse.rs receiver.rs

atty

aws

kms.rs lib.rs s3.rs util.rs

backtrace

backtrace

libunwind.rs mod.rs

symbolize

dladdr.rs libbacktrace.rs mod.rs

capture.rs lib.rs print.rs types.rs

backtrace_sys

backup

endpoint.rs errors.rs lib.rs metrics.rs service.rs writer.rs

base64

read

decoder.rs mod.rs

write

encoder.rs mod.rs

chunked_encoder.rs decode.rs display.rs encode.rs lib.rs tables.rs

batch_system

batch.rs config.rs fsm.rs lib.rs mailbox.rs router.rs

bitfield

bitflags

block_buffer

boolinator

bstr

byteorder

bytes

buf

buf_impl.rs buf_mut.rs chain.rs iter.rs limit.rs mod.rs reader.rs take.rs uninit_slice.rs vec_deque.rs writer.rs

fmt

debug.rs hex.rs mod.rs

bytes.rs bytes_mut.rs lib.rs loom.rs

bzip2_sys

cargo_metadata

dependency.rs diagnostic.rs errors.rs lib.rs messages.rs

cdc

channel.rs delegate.rs endpoint.rs errors.rs lib.rs metrics.rs observer.rs old_value.rs service.rs

cfg_if

chrono

format

mod.rs parse.rs parsed.rs scan.rs strftime.rs

naive

date.rs datetime.rs internals.rs isoweek.rs time.rs

offset

fixed.rs local.rs mod.rs utc.rs

date.rs datetime.rs div.rs lib.rs round.rs

chrono_tz

binary_search.rs directory.rs lib.rs timezone_impl.rs timezones.rs

clap

cloud

blob.rs error.rs kms.rs lib.rs

codec

buffer.rs byte.rs convert.rs error.rs lib.rs number.rs

collections

concurrency_manager

key_handle.rs lib.rs lock_table.rs

configuration

configuration_derive

const_fn

ast.rs error.rs iter.rs lib.rs to_tokens.rs utils.rs

const_random

const_random_macro

coprocessor_plugin_api

allocator.rs errors.rs lib.rs plugin_api.rs storage_api.rs util.rs

cpuid_bool

crc32fast

specialized

mod.rs pclmulqdq.rs

baseline.rs combine.rs lib.rs table.rs

crc64fast

lib.rs pclmulqdq.rs table.rs

crossbeam

crossbeam_channel

flavors

array.rs at.rs list.rs mod.rs never.rs tick.rs zero.rs

channel.rs context.rs counter.rs err.rs lib.rs select.rs select_macro.rs utils.rs waker.rs

crossbeam_deque

deque.rs lib.rs

crossbeam_epoch

sync

list.rs mod.rs queue.rs

atomic.rs collector.rs default.rs deferred.rs epoch.rs guard.rs internal.rs lib.rs

crossbeam_queue

array_queue.rs lib.rs seg_queue.rs

crossbeam_skiplist

base.rs lib.rs map.rs set.rs

crossbeam_utils

atomic

atomic_cell.rs consume.rs mod.rs seq_lock.rs

sync

mod.rs parker.rs sharded_lock.rs wait_group.rs

backoff.rs cache_padded.rs lib.rs thread.rs

crypto_mac

errors.rs lib.rs

darling

lib.rs macros_public.rs

darling_core

darling_macro

dashmap

mapref

entry.rs mod.rs multiple.rs one.rs

setref

mod.rs multiple.rs one.rs

iter.rs iter_set.rs lib.rs lock.rs read_only.rs set.rs t.rs util.rs

debugid

derive_more

digest

digest.rs dyn_digest.rs errors.rs fixed.rs lib.rs variable.rs xof.rs

dirs

dirs_sys

lib.rs xdg_user_dirs.rs

doc_comment

dtoa

diyfp.rs dtoa.rs lib.rs

either

encoding_rs

ascii.rs big5.rs data.rs euc_jp.rs euc_kr.rs gb18030.rs handles.rs iso_2022_jp.rs lib.rs macros.rs mem.rs replacement.rs shift_jis.rs single_byte.rs utf_16.rs utf_8.rs variant.rs x_user_defined.rs

encryption

encrypted_file

header.rs mod.rs

manager

master_key

file.rs kms.rs mem.rs metadata.rs mod.rs

config.rs crypter.rs errors.rs file_dict_file.rs io.rs lib.rs metrics.rs

encryption_export

engine_panic

cf_names.rs cf_options.rs compact.rs db_options.rs db_vector.rs engine.rs import.rs lib.rs misc.rs mvcc_properties.rs perf_context.rs raft_engine.rs range_properties.rs snapshot.rs sst.rs table_properties.rs ttl_properties.rs write_batch.rs

engine_rocks

engine_test

engine_traits

engine_traits_tests

error_code

cloud.rs codec.rs coprocessor.rs encryption.rs engine.rs lib.rs pd.rs raft.rs raftstore.rs sst_importer.rs storage.rs

error_code_gen

example_plugin

external_storage

lib.rs local.rs metrics.rs noop.rs

external_storage_export

export.rs lib.rs

fail

failure

backtrace

internal.rs mod.rs

error

error_impl.rs mod.rs

as_fail.rs box_std.rs compat.rs context.rs error_message.rs lib.rs macros.rs result_ext.rs sync_failure.rs

failure_derive

farmhash

farmhashcc_shared.rs farmhashmk.rs farmhashmk_shared.rs farmhashna.rs farmhashna_shared.rs farmhashuo.rs farmhashxo.rs lib.rs platform.rs

file_system

iosnoop

file.rs lib.rs metrics.rs metrics_manager.rs rate_limiter.rs

filetime

unix

linux.rs mod.rs utimes.rs

flate2

deflate

bufread.rs mod.rs read.rs write.rs

gz

bufread.rs mod.rs read.rs write.rs

zlib

bufread.rs mod.rs read.rs write.rs

bufreader.rs crc.rs ffi.rs lib.rs mem.rs zio.rs

fnv

foreign_types

foreign_types_shared

fs2

futures

futures_channel

mpsc

mod.rs queue.rs sink_impl.rs

lib.rs lock.rs oneshot.rs

futures_core

task

__internal

atomic_waker.rs mod.rs

future.rs lib.rs stream.rs

futures_executor

enter.rs lib.rs local_pool.rs thread_pool.rs unpark_mutex.rs

futures_io

futures_macro

join.rs lib.rs select.rs

futures_sink

futures_task

arc_wake.rs future_obj.rs lib.rs noop_waker.rs spawn.rs waker.rs waker_ref.rs

futures_timer

native

arc_list.rs atomic_waker.rs delay.rs global.rs heap.rs heap_timer.rs timer.rs

lib.rs native.rs

futures_util

async_await

join_mod.rs mod.rs pending.rs poll.rs random.rs select_mod.rs

compat

compat01as03.rs compat03as01.rs executor.rs mod.rs

future

io

lock

bilock.rs mod.rs mutex.rs

sink

buffer.rs close.rs drain.rs err_into.rs fanout.rs feed.rs flush.rs map_err.rs mod.rs send.rs send_all.rs unfold.rs with.rs with_flat_map.rs

stream

task

mod.rs spawn.rs

fns.rs lib.rs never.rs unfold_state.rs

fuzz

fxhash

gcp

generic_array

arr.rs functional.rs hex.rs impls.rs iter.rs lib.rs sequence.rs

getrandom

error.rs error_impls.rs lib.rs linux_android.rs use_file.rs util.rs util_libc.rs

getset

generate.rs lib.rs

grpcio

grpcio_health

proto

health.rs health_grpc.rs

lib.rs proto.rs service.rs

grpcio_sys

grpc_wrap.rs lib.rs

h2

heck

camel.rs kebab.rs lib.rs mixed.rs shouty_snake.rs snake.rs title.rs

hex

error.rs lib.rs

hmac

http

header

map.rs mod.rs name.rs value.rs

uri

authority.rs builder.rs mod.rs path.rs port.rs scheme.rs

byte_str.rs convert.rs error.rs extensions.rs lib.rs method.rs request.rs response.rs status.rs version.rs

http_body

lib.rs next.rs size_hint.rs

httparse

simd

avx2.rs mod.rs sse42.rs

iter.rs lib.rs macros.rs

httpdate

httpdate.rs lib.rs

hyper

body

aggregate.rs body.rs mod.rs to_bytes.rs

client

connect

dns.rs http.rs mod.rs

conn.rs dispatch.rs mod.rs pool.rs service.rs

common

io

mod.rs rewind.rs

buf.rs drain.rs exec.rs lazy.rs mod.rs never.rs sync_wrapper.rs task.rs watch.rs

proto

h1

conn.rs date.rs decode.rs dispatch.rs encode.rs io.rs mod.rs role.rs

h2

client.rs mod.rs ping.rs server.rs

server

accept.rs conn.rs mod.rs shutdown.rs tcp.rs

service

http.rs make.rs mod.rs oneshot.rs util.rs

error.rs headers.rs lib.rs rt.rs upgrade.rs

hyper_openssl

cache.rs lib.rs

hyper_tls

client.rs lib.rs stream.rs

ident_case

idna

lib.rs punycode.rs uts46.rs

indexmap

equivalent.rs lib.rs macros.rs map.rs mutable_keys.rs set.rs util.rs

inferno

collapse

common.rs dtrace.rs guess.rs mod.rs perf.rs sample.rs vtune.rs

differential

flamegraph

color

mod.rs palette_map.rs palettes.rs

attrs.rs merge.rs mod.rs rand.rs svg.rs

inotify

events.rs fd_guard.rs inotify.rs lib.rs util.rs watches.rs

inotify_sys

instant

lib.rs native.rs

into_other

iovec

sys

ipnet

ipext.rs ipnet.rs lib.rs parser.rs

ipnetwork

common.rs ipv4.rs ipv6.rs lib.rs

itertools

itoa

lib.rs udiv128.rs

keys

lib.rs rewrite.rs

kvproto

lazy_static

inline_lazy.rs lib.rs

lazycell

libc

unix

linux_like

linux

gnu

b64

x86_64

align.rs mod.rs not_x32.rs

align.rs mod.rs

align.rs mod.rs

align.rs mod.rs

fixed_width_ints.rs lib.rs macros.rs

libflate

deflate

decode.rs encode.rs mod.rs symbol.rs

non_blocking

deflate

decode.rs mod.rs

gzip.rs mod.rs transaction.rs zlib.rs

bit.rs checksum.rs finish.rs gzip.rs huffman.rs lib.rs lz77.rs util.rs zlib.rs

libflate_lz77

default.rs lib.rs

libloading

os

unix

consts.rs mod.rs

changelog.rs error.rs lib.rs util.rs

librocksdb_sys

generated.rs lib.rs

libtitan_sys

libz_sys

linked_hash_map

linked_hash_set

lock_api

lib.rs mutex.rs remutex.rs rwlock.rs

log

lib.rs macros.rs

log_wrappers

hex.rs lib.rs test_util.rs

lz4_sys

match_template

matches

md5

memchr

x86

avx.rs mod.rs sse2.rs

fallback.rs iter.rs lib.rs naive.rs

memmap

memoffset

lib.rs offset_of.rs raw_field.rs span_of.rs

memory_trace_macros

mime

lib.rs parse.rs

mime_guess

impl_bin_search.rs lib.rs

mio

mio_extras

channel.rs lib.rs timer.rs

mio_uds

datagram.rs lib.rs listener.rs socket.rs stream.rs

more_asserts

murmur3

lib.rs murmur3_32.rs murmur3_x64_128.rs murmur3_x86_128.rs

native_tls

imp

net2

sys

unix

impls.rs mod.rs

ext.rs lib.rs socket.rs tcp.rs udp.rs unix.rs utils.rs

nix

nodrop

nom

bits

complete.rs macros.rs mod.rs streaming.rs

branch

macros.rs mod.rs

bytes

complete.rs macros.rs mod.rs streaming.rs

character

complete.rs macros.rs mod.rs streaming.rs

combinator

macros.rs mod.rs

multi

macros.rs mod.rs

number

complete.rs macros.rs mod.rs streaming.rs

sequence

macros.rs mod.rs

error.rs internal.rs lib.rs methods.rs str.rs traits.rs util.rs whitespace.rs

notify

debounce

mod.rs timer.rs

inotify.rs lib.rs null.rs poll.rs

num

num_complex

cast.rs lib.rs pow.rs

num_cpus

lib.rs linux.rs

num_derive

num_format

impls

buffer.rs constants.rs custom_format.rs custom_format_builder.rs error.rs error_kind.rs format.rs grouping.rs impls.rs lib.rs locale.rs strings.rs to_formatted_str.rs

num_integer

average.rs lib.rs roots.rs

num_iter

num_rational

num_traits

ops

checked.rs inv.rs mod.rs mul_add.rs saturating.rs wrapping.rs

bounds.rs cast.rs float.rs identities.rs int.rs lib.rs macros.rs pow.rs real.rs sign.rs

once_cell

imp_std.rs lib.rs race.rs

opaque_debug

openssl

openssl_probe

openssl_sys

ordered_float

panic_hook

parking_lot

condvar.rs deadlock.rs elision.rs fair_mutex.rs lib.rs mutex.rs once.rs raw_fair_mutex.rs raw_mutex.rs raw_rwlock.rs remutex.rs rwlock.rs util.rs

parking_lot_core

thread_parker

linux.rs mod.rs

lib.rs parking_lot.rs spinwait.rs util.rs word_lock.rs

paste

paste_impl

enum_hack.rs error.rs lib.rs

pd_client

client.rs config.rs errors.rs feature_gate.rs lib.rs metrics.rs util.rs

percent_encoding

pest

iterators

flat_pairs.rs mod.rs pair.rs pairs.rs queueable_token.rs tokens.rs

unicode

binary.rs category.rs mod.rs

error.rs lib.rs macros.rs parser.rs parser_state.rs position.rs prec_climber.rs span.rs stack.rs token.rs

pin_project

pin_project_lite

pin_utils

lib.rs projection.rs stack_pin.rs

pnet_base

lib.rs macaddr.rs

pnet_datalink

bindings

linux.rs mod.rs

dummy.rs lib.rs linux.rs

pnet_sys

pprof

collector.rs error.rs frames.rs lib.rs profiler.rs report.rs timer.rs

ppv_lite86

x86_64

lib.rs soft.rs types.rs

proc_macro2

detection.rs fallback.rs lib.rs marker.rs parse.rs wrapper.rs

proc_macro_error

imp

diagnostic.rs dummy.rs lib.rs macros.rs

proc_macro_error_attr

proc_macro_hack

error.rs iter.rs lib.rs parse.rs quote.rs

proc_macro_nested

procfs

process

limit.rs mod.rs mount.rs stat.rs status.rs

sys

kernel.rs mod.rs vm.rs

cgroups.rs cpuinfo.rs diskstats.rs lib.rs meminfo.rs net.rs pressure.rs

procinfo

net

pid

cpu.rs cwd.rs io.rs limits.rs mod.rs mountinfo.rs stat.rs statm.rs status.rs

sys

fs

file_max.rs mod.rs

lib.rs loadavg.rs parsers.rs

profiler

lib.rs profiler_dummy.rs

prometheus

encoder

mod.rs pb.rs text.rs

proto

atomic64.rs auto_flush.rs counter.rs desc.rs errors.rs gauge.rs histogram.rs lib.rs macros.rs metrics.rs push.rs registry.rs timer.rs value.rs vec.rs

prometheus_static_metric

auto_flush_builder.rs auto_flush_from.rs builder.rs lib.rs parser.rs register_macro.rs util.rs

promptly

from_str.rs lib.rs path.rs yes_no.rs

prost

encoding.rs error.rs lib.rs message.rs types.rs

prost_derive

field

group.rs map.rs message.rs mod.rs oneof.rs scalar.rs

protobuf

quick_xml

events

attributes.rs mod.rs

errors.rs escape.rs lib.rs reader.rs utils.rs writer.rs

quote

ext.rs format.rs ident_fragment.rs lib.rs runtime.rs spanned.rs to_tokens.rs

raft

raft_engine

cache_evict.rs codec.rs config.rs engine.rs errors.rs lib.rs log_batch.rs memtable.rs pipe_log.rs purge.rs util.rs

raft_log_engine

engine.rs lib.rs

raft_proto

confchange.rs confstate.rs lib.rs

raftstore

rand

distributions

bernoulli.rs float.rs integer.rs mod.rs other.rs uniform.rs utils.rs weighted.rs weighted_index.rs

rngs

adapter

mod.rs read.rs reseeding.rs

mock.rs mod.rs std.rs thread.rs

seq

index.rs mod.rs

lib.rs prelude.rs rng.rs

rand_chacha

chacha.rs guts.rs lib.rs

rand_core

block.rs error.rs impls.rs le.rs lib.rs os.rs

rand_isaac

isaac.rs isaac64.rs isaac_array.rs lib.rs

rayon

delegate.rs lib.rs math.rs option.rs par_either.rs prelude.rs private.rs range.rs range_inclusive.rs result.rs split_producer.rs str.rs string.rs vec.rs

rayon_core

compile_fail

mod.rs quicksort_race1.rs quicksort_race2.rs quicksort_race3.rs rc_return.rs rc_upvar.rs scope_join_bad.rs

join

scope

sleep

counters.rs mod.rs

spawn

thread_pool

job.rs latch.rs lib.rs log.rs private.rs registry.rs unwind.rs util.rs

regex

regex_automata

classes.rs dense.rs dfa.rs lib.rs regex.rs sparse.rs state_id.rs

regex_syntax

remove_dir_all

reqwest

resolved_ts

advance.rs cmd.rs endpoint.rs errors.rs lib.rs metrics.rs observer.rs resolver.rs scanner.rs sinker.rs

rev_lines

rgb

internal

convert

array.rs mod.rs tuple.rs

ops.rs pixel.rs rgb.rs rgba.rs

ring

rle_decode_fast

rocksdb

rusoto_core

proto

json

error.rs mod.rs payload.rs

xml

error.rs mod.rs util.rs

client.rs encoding.rs error.rs event_stream.rs lib.rs param.rs region.rs request.rs serialization.rs signature.rs stream.rs

rusoto_credential

claims.rs container.rs environment.rs instance_metadata.rs lib.rs profile.rs request.rs secrets.rs static_provider.rs variable.rs

rusoto_kms

custom

generated.rs lib.rs

rusoto_s3

custom

generated.rs lib.rs

rusoto_signature

lib.rs region.rs signature.rs stream.rs

rusoto_sts

custom

credential.rs mod.rs web_identity.rs

generated.rs lib.rs

rustc_demangle

legacy.rs lib.rs v0.rs

rustyline

tty

completion.rs config.rs edit.rs error.rs highlight.rs hint.rs history.rs keymap.rs keys.rs kill_ring.rs layout.rs lib.rs line_buffer.rs undo.rs validate.rs

ryu

buffer

pretty

exponent.rs mantissa.rs mod.rs

common.rs d2s.rs d2s_full_table.rs d2s_intrinsics.rs digit_table.rs f2s.rs lib.rs

safemem

same_file

scopeguard

security

semver

lib.rs version.rs version_req.rs

semver_parser

generated.rs lexer.rs lib.rs parser.rs range.rs range_set.rs version.rs

serde

de

from_primitive.rs ignored_any.rs impls.rs mod.rs utf8.rs value.rs

private

de.rs macros.rs mod.rs ser.rs

ser

impls.rs impossible.rs mod.rs

export.rs integer128.rs lib.rs macros.rs

serde_derive

internals

ast.rs attr.rs case.rs check.rs ctxt.rs mod.rs symbol.rs

bound.rs de.rs dummy.rs fragment.rs lib.rs pretend.rs ser.rs try.rs

serde_ignored

serde_json

features_check

io

value

de.rs from.rs index.rs mod.rs partial_eq.rs ser.rs

de.rs error.rs iter.rs lib.rs macros.rs map.rs number.rs read.rs ser.rs

serde_urlencoded

ser

key.rs mod.rs pair.rs part.rs value.rs

serde_with

duplicate_key_impls

error_on_duplicate.rs first_value_wins.rs mod.rs

flatten_maybe.rs lib.rs rust.rs with_prefix.rs

serde_with_macros

server

lib.rs raft_engine_switch.rs server.rs setup.rs signal_handler.rs

sha2

sha256

sha512

consts.rs lib.rs sha256.rs sha512.rs

shlex

signal

exec_handler.rs ffi.rs lib.rs trap.rs

signal_hook_registry

half_lock.rs lib.rs

slab

slog

key

mod.rs static.rs

slog_async

slog_derive

derive_kv.rs derive_serde_value.rs lib.rs utils.rs

slog_global

lib.rs log_redirect.rs

slog_json

slog_term

smallvec

snappy_sys

socket2

sys

lib.rs sockaddr.rs socket.rs utils.rs

spin

lib.rs mutex.rs once.rs rw_lock.rs

sst_importer

config.rs errors.rs import_mode.rs lib.rs metrics.rs service.rs sst_importer.rs util.rs

stable_deref_trait

standback

static_assertions

assert_cfg.rs assert_eq_align.rs assert_eq_size.rs assert_fields.rs assert_impl.rs assert_obj_safe.rs assert_trait.rs assert_type.rs const_assert.rs lib.rs

str_stack

strsim

structopt

structopt_derive

attrs.rs doc_comments.rs lib.rs parse.rs spanned.rs ty.rs

strum

additional_attributes.rs lib.rs

strum_macros

helpers

case_style.rs metadata.rs mod.rs type_props.rs variant_props.rs

macros

strings

as_ref_str.rs display.rs from_string.rs mod.rs to_string.rs

enum_count.rs enum_discriminants.rs enum_iter.rs enum_messages.rs enum_properties.rs enum_variant_names.rs mod.rs

subtle

symbolic_common

byteview.rs cell.rs heuristics.rs lib.rs path.rs types.rs

symbolic_demangle

syn

syn_mid

arg.rs lib.rs macros.rs pat.rs path.rs

synstructure

lib.rs macros.rs

sysinfo

linux

component.rs disk.rs mod.rs network.rs process.rs processor.rs system.rs users.rs

common.rs debug.rs lib.rs system.rs traits.rs utils.rs

take_mut

lib.rs scoped.rs

tame_gcs

v1

objects

delete.rs download.rs get.rs insert.rs list.rs mod.rs patch.rs

common.rs mod.rs

error.rs lib.rs response.rs signed_url.rs signing.rs types.rs util.rs

tame_oauth

gcp

error.rs lib.rs token.rs

tempfile

file

imp

dir.rs error.rs lib.rs spooled.rs util.rs

term

terminfo

parser

compiled.rs names.rs

mod.rs parm.rs searcher.rs

test_backup

test_coprocessor

column.rs dag.rs fixture.rs lib.rs store.rs table.rs util.rs

test_pd

mocker

bootstrap.rs incompatible.rs leader_change.rs mod.rs retry.rs service.rs split.rs

lib.rs server.rs util.rs

test_raftstore

cluster.rs lib.rs node.rs pd.rs router.rs server.rs transport_simulate.rs util.rs

test_sst_importer

test_storage

assert_storage.rs lib.rs sync_storage.rs util.rs

test_util

encryption.rs kv_generator.rs lib.rs logging.rs macros.rs runner.rs security.rs

textwrap

indentation.rs lib.rs splitting.rs

thiserror

aserror.rs display.rs lib.rs

thiserror_impl

ast.rs attr.rs expand.rs fmt.rs lib.rs prop.rs valid.rs

thread_local

cached.rs lib.rs thread_id.rs unreachable.rs

tidb_query_aggr

impl_avg.rs impl_bit_op.rs impl_count.rs impl_first.rs impl_max_min.rs impl_sum.rs impl_variance.rs lib.rs parser.rs summable.rs util.rs

tidb_query_codegen

aggr_function.rs lib.rs rpn_function.rs

tidb_query_common

storage

mod.rs range.rs ranges_iter.rs scanner.rs test_fixture.rs

error.rs execute_stats.rs lib.rs macros.rs metrics.rs util.rs

tidb_query_datatype

builder

field_type.rs mod.rs

codec

def

eval_type.rs field_type.rs mod.rs

expr

error.rs lib.rs

tidb_query_executors

util

aggr_executor.rs hash_aggr_helper.rs mod.rs scan_executor.rs

fast_hash_aggr_executor.rs index_scan_executor.rs interface.rs lib.rs limit_executor.rs runner.rs selection_executor.rs simple_aggr_executor.rs slow_hash_aggr_executor.rs stream_aggr_executor.rs table_scan_executor.rs top_n_executor.rs

tidb_query_expr

tikv

coprocessor

dag

mod.rs storage_impl.rs

interceptors

concurrency_limiter.rs deadline.rs mod.rs tracker.rs

statistics

analyze.rs cmsketch.rs fmsketch.rs histogram.rs mod.rs

cache.rs checksum.rs endpoint.rs error.rs metrics.rs mod.rs readpool_impl.rs tracker.rs

coprocessor_v2

config.rs endpoint.rs mod.rs plugin_registry.rs raw_storage_impl.rs

import

mod.rs sst_service.rs

server

gc_worker

applied_lock_collector.rs compaction_filter.rs config.rs gc_manager.rs gc_worker.rs mod.rs

load_statistics

linux.rs mod.rs

lock_manager

client.rs config.rs deadlock.rs metrics.rs mod.rs waiter_manager.rs

service

diagnostics

ioload.rs log.rs mod.rs sys.rs

batch.rs debug.rs kv.rs mod.rs

status_server

mod.rs region_meta.rs

ttl

mod.rs ttl_checker.rs ttl_compaction_filter.rs

config.rs debug.rs errors.rs metrics.rs mod.rs node.rs proxy.rs raft_client.rs raftkv.rs resolve.rs server.rs snap.rs transport.rs

storage

config.rs lib.rs read_pool.rs

tikv_alloc

error.rs jemalloc.rs lib.rs trace.rs

tikv_ctl

tikv_jemalloc_ctl

arenas.rs config.rs error.rs keys.rs lib.rs macros.rs opt.rs raw.rs stats.rs thread.rs

tikv_jemalloc_sys

tikv_jemallocator

tikv_kv

btree_engine.rs cursor.rs lib.rs metrics.rs mock_engine.rs perf_context.rs raftstore_impls.rs rocksdb_engine.rs stats.rs

tikv_server

tikv_util

time

time_macros

time_macros_impl

time_crate

date.rs ext.rs lib.rs offset.rs shim.rs time.rs

tipb

tipb_helper

expr_def_builder.rs lib.rs

tokio

fs

future

maybe_done.rs mod.rs poll_fn.rs ready.rs try_join.rs

io

loom

std

atomic_ptr.rs atomic_u16.rs atomic_u32.rs atomic_u64.rs atomic_u8.rs atomic_usize.rs mod.rs unsafe_cell.rs

macros

cfg.rs join.rs loom.rs mod.rs pin.rs ready.rs scoped_tls.rs select.rs support.rs thread_local.rs try_join.rs

net

park

either.rs mod.rs thread.rs

process

unix

mod.rs orphan.rs reap.rs

runtime

signal

ctrl_c.rs mod.rs registry.rs unix.rs

stream

all.rs any.rs chain.rs collect.rs empty.rs filter.rs filter_map.rs fold.rs fuse.rs iter.rs map.rs merge.rs mod.rs next.rs once.rs pending.rs skip.rs skip_while.rs stream_map.rs take.rs take_while.rs timeout.rs try_next.rs

sync

task

blocking.rs local.rs mod.rs spawn.rs task_local.rs yield_now.rs

time

driver

atomic_stack.rs entry.rs handle.rs mod.rs registration.rs stack.rs

wheel

level.rs mod.rs stack.rs

clock.rs delay.rs delay_queue.rs error.rs instant.rs interval.rs mod.rs throttle.rs timeout.rs

util

slab

addr.rs entry.rs generation.rs mod.rs page.rs shard.rs slot.rs stack.rs

bit.rs intrusive_double_linked_list.rs linked_list.rs mod.rs rand.rs trace.rs try_lock.rs wake.rs

coop.rs lib.rs prelude.rs

tokio_executor

enter.rs error.rs executor.rs global.rs lib.rs park.rs typed.rs

tokio_macros

entry.rs lib.rs select.rs

tokio_openssl

tokio_timer

tokio_tls

tokio_util

codec

bytes_codec.rs decoder.rs encoder.rs framed.rs framed_read.rs framed_write.rs length_delimited.rs lines_codec.rs mod.rs

toml

datetime.rs de.rs lib.rs macros.rs map.rs ser.rs spanned.rs tokens.rs value.rs

tower_service

tracing

dispatcher.rs field.rs instrument.rs level_filters.rs lib.rs macros.rs span.rs stdlib.rs subscriber.rs

tracing_core

callsite.rs dispatcher.rs event.rs field.rs lib.rs metadata.rs parent.rs span.rs stdlib.rs subscriber.rs

try_lock

twoway

twox_hash

lib.rs sixty_four.rs thirty_two.rs

txn_types

lib.rs lock.rs timestamp.rs types.rs write.rs

typenum

array.rs bit.rs int.rs lib.rs marker_traits.rs operator_aliases.rs private.rs type_operators.rs uint.rs

ucd_trie

lib.rs owned.rs

unchecked_index

lib.rs slice_impls.rs

unicase

unicode

ascii.rs lib.rs

unicode_bidi

char_data

mod.rs tables.rs

deprecated.rs explicit.rs format_chars.rs implicit.rs level.rs lib.rs prepare.rs

unicode_normalization

__test_api.rs decompose.rs lib.rs lookups.rs normalize.rs perfect_hash.rs quick_check.rs recompose.rs stream_safe.rs tables.rs

unicode_segmentation

grapheme.rs lib.rs sentence.rs tables.rs word.rs

unicode_width

lib.rs tables.rs

unicode_xid

lib.rs tables.rs

untrusted

url

form_urlencoded.rs host.rs lib.rs origin.rs parser.rs path_segments.rs query_encoding.rs quirks.rs slicing.rs

utf8parse

lib.rs types.rs

uuid

adapter

compact.rs mod.rs

builder

error.rs mod.rs

parser

error.rs mod.rs

error.rs lib.rs prelude.rs serde_support.rs v4.rs

vec_map

vlog

lib.rs macros.rs

walkdir

dent.rs error.rs lib.rs util.rs

want

xml

yatp

pool

builder.rs runner.rs spawn.rs worker.rs

queue

extras.rs multilevel.rs single_level.rs

task

callback.rs future.rs

lib.rs metrics.rs pool.rs queue.rs task.rs

zeroize

zstd_sys

bindings.rs lib.rs

use core::fmt;
use core::pin::Pin;
use futures_core::future::TryFuture;
use futures_core::ready;
use futures_core::stream::{Stream, TryStream, FusedStream};
use futures_core::task::{Context, Poll};
#[cfg(feature = "sink")]
use futures_sink::Sink;
use pin_project_lite::pin_project;

pin_project! {
    /// Stream for the [`and_then`](super::TryStreamExt::and_then) method.
    #[must_use = "streams do nothing unless polled"]
    pub struct AndThen<St, Fut, F> {
        #[pin]
        stream: St,
        #[pin]
        future: Option<Fut>,
        f: F,
    }
}

impl<St, Fut, F> fmt::Debug for AndThen<St, Fut, F>
where
    St: fmt::Debug,
    Fut: fmt::Debug,
{
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        f.debug_struct("AndThen")
            .field("stream", &self.stream)
            .field("future", &self.future)
            .finish()
    }
}

impl<St, Fut, F> AndThen<St, Fut, F>
    where St: TryStream,
          F: FnMut(St::Ok) -> Fut,
          Fut: TryFuture<Error = St::Error>,
{
    pub(super) fn new(stream: St, f: F) -> Self {
        Self { stream, future: None, f }
    }

    delegate_access_inner!(stream, St, ());
}

impl<St, Fut, F> Stream for AndThen<St, Fut, F>
    where St: TryStream,
          F: FnMut(St::Ok) -> Fut,
          Fut: TryFuture<Error = St::Error>,
{
    type Item = Result<Fut::Ok, St::Error>;

    fn poll_next(
        self: Pin<&mut Self>,
        cx: &mut Context<'_>,
    ) -> Poll<Option<Self::Item>> {
        let mut this = self.project();

        Poll::Ready(loop {
            if let Some(fut) = this.future.as_mut().as_pin_mut() {
                let item = ready!(fut.try_poll(cx));
                this.future.set(None);
                break Some(item);
            } else if let Some(item) = ready!(this.stream.as_mut().try_poll_next(cx)?) {
                this.future.set(Some((this.f)(item)));
            } else {
                break None;
            }
        })
    }

    fn size_hint(&self) -> (usize, Option<usize>) {
        let future_len = if self.future.is_some() { 1 } else { 0 };
        let (lower, upper) = self.stream.size_hint();
        let lower = lower.saturating_add(future_len);
        let upper = match upper {
            Some(x) => x.checked_add(future_len),
            None => None,
        };
        (lower, upper)
    }
}

impl<St, Fut, F> FusedStream for AndThen<St, Fut, F>
    where St: TryStream + FusedStream,
          F: FnMut(St::Ok) -> Fut,
          Fut: TryFuture<Error = St::Error>,
{
    fn is_terminated(&self) -> bool {
        self.future.is_none() && self.stream.is_terminated()
    }
}

// Forwarding impl of Sink from the underlying stream
#[cfg(feature = "sink")]
impl<S, Fut, F, Item> Sink<Item> for AndThen<S, Fut, F>
    where S: Sink<Item>,
{
    type Error = S::Error;

    delegate_sink!(stream, Item);
}