select_next_some.rs.html -- source

Files

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

dladdr.rs libbacktrace.rs mod.rs

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

backtrace_sys

bitflags

blindbid

blindbid.rs buffer.rs gadgets.rs main.rs pipe.rs

block_buffer

block_padding

bulletproofs

r1cs

constraint_system.rs linear_combination.rs mod.rs proof.rs prover.rs verifier.rs

range_proof

dealer.rs messages.rs mod.rs party.rs

errors.rs generators.rs inner_product_proof.rs lib.rs transcript.rs util.rs

byte_tools

byteorder

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

clap

clear_on_drop

clear.rs clear_on_drop.rs clear_stack_on_return.rs fnoption.rs hide.rs lib.rs

curve25519_dalek

backend

serial

curve_models

scalar_mul

mod.rs pippenger.rs precomputed_straus.rs straus.rs variable_base.rs vartime_double_base.rs

u64

constants.rs field.rs mod.rs scalar.rs

constants.rs edwards.rs field.rs lib.rs macros.rs montgomery.rs prelude.rs ristretto.rs scalar.rs traits.rs window.rs

digest

digest.rs dyn_digest.rs errors.rs lib.rs

dusk_blindbidproof

blindbid

mod.rs proof.rs verify.rs

futures

main.rs mod.rs prove.rs verify.rs

error.rs gadgets.rs lib.rs

dusk_tlv

error.rs lib.rs reader.rs writer.rs

dusk_uds

communication.rs lib.rs options.rs uds.rs worker.rs

env_logger

filter

mod.rs regex.rs

fmt

humantime

extern_impl.rs mod.rs

writer

termcolor

extern_impl.rs mod.rs

failure

backtrace

as_fail.rs compat.rs context.rs lib.rs result_ext.rs

failure_derive

fake_simd

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

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

sink

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

stream

task

mod.rs spawn.rs

lib.rs never.rs

generic_array

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

humantime

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

keccak

lazy_static

inline_lazy.rs lib.rs

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

log

lib.rs macros.rs

memchr

x86

avx.rs mod.rs sse2.rs

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

merlin

constants.rs lib.rs strobe.rs transcript.rs

num_cpus

num_integer

lib.rs roots.rs

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

opaque_debug

packed_simd

api

bit_manip.rs bitmask.rs cast.rs cmp.rs default.rs fmt.rs from.rs hash.rs into_bits.rs math.rs minimal.rs ops.rs ptr.rs reductions.rs select.rs shuffle.rs shuffle1_dyn.rs slice.rs swap_bytes.rs

codegen

testing

api.rs codegen.rs lib.rs masks.rs sealed.rs testing.rs v128.rs v16.rs v256.rs v32.rs v512.rs v64.rs vPtr.rs vSize.rs

pin_utils

lib.rs projection.rs stack_pin.rs

proc_macro2

fallback.rs lib.rs strnom.rs wrapper.rs

proc_macro_hack

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

rand_core

rand_hc

hc128.rs lib.rs

rand_isaac

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

rand_jitter

dummy_log.rs error.rs lib.rs platform.rs

rand_os

dummy_log.rs lib.rs linux_android.rs random_device.rs

rand_pcg

lib.rs pcg128.rs pcg64.rs

rand_xorshift

regex

regex_syntax

rustc_demangle

legacy.rs lib.rs v0.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

sha2

consts.rs lib.rs sha256.rs sha256_utils.rs sha512.rs sha512_utils.rs

sha3

lib.rs macros.rs paddings.rs reader.rs state.rs

slab

strsim

subtle

syn

synstructure

lib.rs macros.rs

termcolor

textwrap

indentation.rs lib.rs splitting.rs

thread_local

lib.rs thread_id.rs unreachable.rs

time

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

typenum

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

unicode_width

lib.rs tables.rs

unicode_xid

lib.rs tables.rs

vec_map

use core::pin::Pin;
use futures_core::stream::FusedStream;
use futures_core::future::{Future, FusedFuture};
use futures_core::task::{Context, Poll};
use crate::stream::StreamExt;

/// Future for the [`select_next_some`](super::StreamExt::select_next_some)
/// method.
#[derive(Debug)]
#[must_use = "futures do nothing unless you `.await` or poll them"]
pub struct SelectNextSome<'a, St: ?Sized> {
    stream: &'a mut St,
}

impl<'a, St: ?Sized> SelectNextSome<'a, St> {
    pub(super) fn new(stream: &'a mut St) -> Self {
        SelectNextSome { stream }
    }
}

impl<St: ?Sized + FusedStream + Unpin> FusedFuture for SelectNextSome<'_, St> {
    fn is_terminated(&self) -> bool {
        self.stream.is_terminated()
    }
}

impl<St: ?Sized + FusedStream + Unpin> Future for SelectNextSome<'_, St> {
    type Output = St::Item;

    fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> {
        assert!(!self.stream.is_terminated(), "SelectNextSome polled after terminated");

        if let Some(item) = ready!(self.stream.poll_next_unpin(cx)) {
            Poll::Ready(item)
        } else {
            debug_assert!(self.stream.is_terminated());
            cx.waker().wake_by_ref();
            Poll::Pending
        }
    }
}

Keyboard Shortcuts

?: Show this help dialog
S: Focus the search field
↑: Move up in search results
↓: Move down in search results
↹: Switch tab
⏎: Go to active search result
+: Expand all sections
-: Collapse all sections

Search Tricks

Prefix searches with a type followed by a colon (e.g., fn:) to restrict the search to a given type.

Accepted types are: fn, mod, struct, enum, trait, type, macro, and const.

Search functions by type signature (e.g., vec -> usize or * -> vec)

Search multiple things at once by splitting your query with comma (e.g., str,u8 or String,struct:Vec,test)

You can look for items with an exact name by putting double quotes around your request: "string"

Look for items inside another one by searching for a path: vec::Vec