and_then.rs - source

Files

addr2line

adler

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

atty

backtrace

backtrace

libunwind.rs mod.rs

symbolize

gimli

elf.rs mmap_unix.rs stash.rs

gimli.rs mod.rs

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

base64

read

decoder.rs mod.rs

write

encoder.rs encoder_string_writer.rs mod.rs

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

bincode

config

endian.rs int.rs legacy.rs limit.rs mod.rs trailing.rs

de

ser

byteorder.rs error.rs internal.rs lib.rs

bitflags

bitmaps

bitmap.rs lib.rs types.rs

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

bytesize

cargo

core

ops

sources

git

mod.rs source.rs utils.rs

registry

index.rs local.rs mod.rs remote.rs

config.rs directory.rs mod.rs path.rs replaced.rs

util

lib.rs macros.rs

cargo_platform

cfg.rs error.rs lib.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

sys

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

clap

color_backtrace

corpus_database

data_structures.rs lib.rs storage.rs

corpus_database_dsl

generator

counters.rs debug.rs interning_tables.rs loader.rs merge.rs mod.rs registration.rs relations.rs storage.rs types.rs utils.rs

ast.rs lib.rs parser.rs queries.rs

corpus_extractor

check_unsafety.rs converters.rs hir_visitor.rs lib.rs mir_visitor.rs mirai_utils.rs table_filler.rs

corpus_manager

corpus_manager_driver

corpus_queries_derive

corpus_queries_impl

crates_index

crates_io

crc32fast

specialized

mod.rs pclmulqdq.rs

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

crossbeam_queue

array_queue.rs err.rs lib.rs seg_queue.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_hash

imp

csv

byte_record.rs cookbook.rs deserializer.rs error.rs lib.rs reader.rs serializer.rs string_record.rs tutorial.rs writer.rs

csv_core

lib.rs reader.rs writer.rs

curl

easy

form.rs handle.rs handler.rs list.rs mod.rs windows.rs

error.rs lib.rs multi.rs panic.rs version.rs

curl_sys

darling

lib.rs macros_public.rs

darling_core

darling_macro

datafrog

join.rs lib.rs map.rs treefrog.rs

datapond

generator_new

ast.rs encode.rs mod.rs to_tokens.rs

parser

ast.rs data_structures.rs generator.rs lib.rs typechecker.rs

datapond_derive

datapond_macro

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

env_logger

filter

mod.rs regex.rs

fmt

humantime

extern_impl.rs mod.rs

writer

termcolor

extern_impl.rs mod.rs

error_chain

backtrace.rs error_chain.rs example_generated.rs impl_error_chain_kind.rs lib.rs quick_main.rs

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

filetime

unix

linux.rs mod.rs utimes.rs

flate2

deflate

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

ffi

gz

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

zlib

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

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

fnv

foreign_types

foreign_types_shared

form_urlencoded

lib.rs query_encoding.rs

fs2

futures

future

sink

buffer.rs fanout.rs flush.rs from_err.rs map_err.rs mod.rs send.rs send_all.rs wait.rs with.rs with_flat_map.rs

stream

sync

mpsc

mod.rs queue.rs

bilock.rs mod.rs oneshot.rs

task_impl

std

data.rs mod.rs task_rc.rs unpark_mutex.rs

atomic_task.rs core.rs mod.rs

unsync

mod.rs mpsc.rs oneshot.rs

executor.rs lib.rs lock.rs poll.rs resultstream.rs task.rs

futures_channel

mpsc

mod.rs queue.rs

lib.rs lock.rs oneshot.rs

futures_core

task

__internal

atomic_waker.rs mod.rs

future.rs lib.rs stream.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_util

async_await

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

future

io

lock

bilock.rs mod.rs mutex.rs

stream

task

mod.rs spawn.rs

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

getrandom

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

gimli

git2

git2_curl

glob

globset

glob.rs lib.rs pathutil.rs

h2

hashbrown

external_trait_impls

raw

bitmask.rs mod.rs sse2.rs

lib.rs macros.rs map.rs scopeguard.rs set.rs

heck

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

hex

error.rs lib.rs

home

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

humantime

date.rs duration.rs lib.rs wrapper.rs

hyper

body

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

client

connect

dns.rs http.rs mod.rs

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

common

io

mod.rs rewind.rs

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

proto

h1

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

h2

client.rs mod.rs ping.rs

service

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

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

hyper_tls

client.rs lib.rs stream.rs

ident_case

idna

lib.rs punycode.rs uts46.rs

ignore

default_types.rs dir.rs gitignore.rs lib.rs overrides.rs pathutil.rs types.rs walk.rs

im_rc

hash

map.rs mod.rs set.rs

nodes

btree.rs hamt.rs mod.rs rrb.rs

ord

map.rs mod.rs set.rs

vector

focus.rs mod.rs pool.rs

config.rs fakepool.rs iter.rs lib.rs sort.rs sync.rs util.rs

indexmap

map

core

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

iovec

sys

ipnet

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

itertools

itoa

jobserver

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

libgit2_sys

libnghttp2_sys

libssh2_sys

libz_sys

lock_api

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

log

lib.rs macros.rs

log_derive

matches

maybe_uninit

memchr

x86

avx.rs mod.rs sse2.rs

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

mime

lib.rs parse.rs

miniz_oxide

deflate

buffer.rs core.rs mod.rs stream.rs

inflate

core.rs mod.rs output_buffer.rs stream.rs

lib.rs shared.rs

mio

event

event.rs events.rs mod.rs source.rs

net

tcp

listener.rs mod.rs socket.rs stream.rs

uds

datagram.rs listener.rs mod.rs stream.rs

sys

unix

selector

epoll.rs mod.rs

uds

datagram.rs listener.rs mod.rs socketaddr.rs stream.rs

mod.rs net.rs pipe.rs sourcefd.rs tcp.rs udp.rs waker.rs

interest.rs io_source.rs lib.rs macros.rs poll.rs token.rs waker.rs

mio_uds

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

native_tls

imp

nix

num_cpus

lib.rs linux.rs

num_integer

average.rs lib.rs roots.rs

num_traits

ops

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

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

object

once_cell

imp_std.rs lib.rs

opener

openssl

openssl_probe

openssl_sys

parking_lot

condvar.rs deadlock.rs elision.rs lib.rs mutex.rs once.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

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

ppv_lite86

x86_64

lib.rs soft.rs types.rs

print_stats

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 sealed.rs

proc_macro_error_attr

lib.rs parse.rs settings.rs

proc_macro_hack

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

proc_macro_nested

quick_error

quote

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

rand

rand_chacha

chacha.rs guts.rs lib.rs

rand_core

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

rand_xoshiro

common.rs lib.rs splitmix64.rs xoroshiro128plus.rs xoroshiro128plusplus.rs xoroshiro128starstar.rs xoroshiro64star.rs xoroshiro64starstar.rs xoshiro128plus.rs xoshiro128plusplus.rs xoshiro128starstar.rs xoshiro256plus.rs xoshiro256plusplus.rs xoshiro256starstar.rs xoshiro512plus.rs xoshiro512plusplus.rs xoshiro512starstar.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

async_impl

body.rs client.rs decoder.rs mod.rs request.rs response.rs

blocking

body.rs client.rs mod.rs request.rs response.rs wait.rs

connect.rs error.rs into_url.rs lib.rs proxy.rs redirect.rs tls.rs util.rs

rustc

rustc_demangle

legacy.rs lib.rs v0.rs

rustc_hash

rustc_workspace_hack

rustfix

diagnostics.rs lib.rs replace.rs

rustwide

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 f2s_intrinsics.rs lib.rs

same_file

scopeguard

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

ignored_any.rs impls.rs mod.rs seed.rs utf8.rs value.rs

private

de.rs doc.rs mod.rs ser.rs size_hint.rs

ser

fmt.rs impls.rs impossible.rs mod.rs

integer128.rs lib.rs macros.rs

serde_derive

internals

ast.rs attr.rs case.rs check.rs ctxt.rs mod.rs receiver.rs respan.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 raw.rs read.rs ser.rs

serde_urlencoded

ser

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

shell_escape

signal_hook_registry

half_lock.rs lib.rs

simplelog

loggers

comblog.rs logging.rs mod.rs simplelog.rs termlog.rs writelog.rs

config.rs lib.rs

sized_chunks

inline_array

ring_buffer

index.rs iter.rs mod.rs slice.rs

sized_chunk

sparse_chunk

lib.rs types.rs

slab

smallvec

socket2

sys

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

strip_ansi_escapes

strsim

structopt

structopt_derive

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

syn

synstructure

lib.rs macros.rs

tar

archive.rs builder.rs entry.rs entry_type.rs error.rs header.rs lib.rs pax.rs

tempdir

tempfile

file

imp

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

termcolor

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

time

display.rs duration.rs lib.rs parse.rs sys.rs

tinyvec

array

generated_impl.rs

array.rs arrayvec.rs arrayvec_drain.rs lib.rs slicevec.rs tinyvec.rs

tinyvec_macros

tokio

future

block_on.rs mod.rs poll_fn.rs ready.rs

io

loom

std

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

macros

cfg.rs loom.rs mod.rs pin.rs ready.rs scoped_tls.rs support.rs thread_local.rs

net

tcp

listener.rs mod.rs socket.rs split.rs split_owned.rs stream.rs

unix

datagram

mod.rs socket.rs

listener.rs mod.rs socketaddr.rs split.rs split_owned.rs stream.rs ucred.rs

addr.rs lookup_host.rs mod.rs udp.rs

park

either.rs mod.rs thread.rs

runtime

sync

task

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

time

driver

wheel

level.rs mod.rs

entry.rs handle.rs mod.rs sleep.rs

clock.rs error.rs instant.rs interval.rs mod.rs timeout.rs

util

bit.rs error.rs linked_list.rs mod.rs rand.rs slab.rs trace.rs try_lock.rs wake.rs

blocking.rs coop.rs lib.rs

tokio_executor

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

tokio_io

tokio_native_tls

tokio_process

unix

mod.rs orphan.rs reap.rs

tokio_reactor

background.rs lib.rs poll_evented.rs registration.rs sharded_rwlock.rs

tokio_signal

tokio_stream

tokio_sync

mpsc

block.rs bounded.rs chan.rs list.rs mod.rs unbounded.rs

task

atomic_task.rs mod.rs

lib.rs lock.rs loom.rs oneshot.rs semaphore.rs watch.rs

tokio_util

codec

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

sync

cancellation_token.rs intrusive_double_linked_list.rs mod.rs

cfg.rs either.rs lib.rs loom.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

tracing_futures

executor

lib.rs stdlib.rs

try_lock

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

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 no_std_prelude.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

url

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

utf8parse

lib.rs table.rs types.rs

vec_map

vte

definitions.rs lib.rs table.rs

walkdir

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

want

xattr

sys

linux_macos

linux.rs mod.rs

error.rs lib.rs util.rs

use {IntoFuture, Future, Poll, Async};
use stream::Stream;

/// A stream combinator which chains a computation onto values produced by a
/// stream.
///
/// This structure is produced by the `Stream::and_then` method.
#[derive(Debug)]
#[must_use = "streams do nothing unless polled"]
pub struct AndThen<S, F, U>
    where U: IntoFuture,
{
    stream: S,
    future: Option<U::Future>,
    f: F,
}

pub fn new<S, F, U>(s: S, f: F) -> AndThen<S, F, U>
    where S: Stream,
          F: FnMut(S::Item) -> U,
          U: IntoFuture<Error=S::Error>,
{
    AndThen {
        stream: s,
        future: None,
        f: f,
    }
}

impl<S, F, U> AndThen<S, F, U>
    where U: IntoFuture,
{
    /// Acquires a reference to the underlying stream that this combinator is
    /// pulling from.
    pub fn get_ref(&self) -> &S {
        &self.stream
    }

    /// Acquires a mutable reference to the underlying stream that this
    /// combinator is pulling from.
    ///
    /// Note that care must be taken to avoid tampering with the state of the
    /// stream which may otherwise confuse this combinator.
    pub fn get_mut(&mut self) -> &mut S {
        &mut self.stream
    }

    /// Consumes this combinator, returning the underlying stream.
    ///
    /// 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.stream
    }
}

// Forwarding impl of Sink from the underlying stream
impl<S, F, U: IntoFuture> ::sink::Sink for AndThen<S, F, U>
    where S: ::sink::Sink
{
    type SinkItem = S::SinkItem;
    type SinkError = S::SinkError;

    fn start_send(&mut self, item: S::SinkItem) -> ::StartSend<S::SinkItem, S::SinkError> {
        self.stream.start_send(item)
    }

    fn poll_complete(&mut self) -> Poll<(), S::SinkError> {
        self.stream.poll_complete()
    }

    fn close(&mut self) -> Poll<(), S::SinkError> {
        self.stream.close()
    }
}

impl<S, F, U> Stream for AndThen<S, F, U>
    where S: Stream,
          F: FnMut(S::Item) -> U,
          U: IntoFuture<Error=S::Error>,
{
    type Item = U::Item;
    type Error = S::Error;

    fn poll(&mut self) -> Poll<Option<U::Item>, S::Error> {
        if self.future.is_none() {
            let item = match try_ready!(self.stream.poll()) {
                None => return Ok(Async::Ready(None)),
                Some(e) => e,
            };
            self.future = Some((self.f)(item).into_future());
        }
        assert!(self.future.is_some());
        match self.future.as_mut().unwrap().poll() {
            Ok(Async::Ready(e)) => {
                self.future = None;
                Ok(Async::Ready(Some(e)))
            }
            Err(e) => {
                self.future = None;
                Err(e)
            }
            Ok(Async::NotReady) => Ok(Async::NotReady)
        }
    }
}