| /external/rust/crates/futures-util/src/stream/stream/ |
| D | peek.rs | 20 pub struct Peekable<St: Stream> {
27 impl<St: Stream> Peekable<St> { impl
65 impl<St: Stream> FusedStream for Peekable<St> { implementation
71 impl<S: Stream> Stream for Peekable<S> { implementation
96 impl<S, Item> Sink<Item> for Peekable<S> implementation
109 inner: Option<Pin<&'a mut Peekable<St>>>,
|
| D | mod.rs | 126 pub use self::peek::{Peek, Peekable};
1264 fn peekable(self) -> Peekable<Self> in peekable()
1268 assert_stream::<Self::Item, _>(Peekable::new(self)) in peekable()
|
| /external/rust/crates/peeking_take_while/src/ |
| D | lib.rs | 61 use std::iter::Peekable;
69 iter: &'a mut Peekable<I>,
106 impl<'a, I> PeekableExt<'a, I> for Peekable<I> implementation
|
| /external/rust/crates/futures/tests/ |
| D | stream_peekable.rs | 5 use futures::stream::{self, Peekable, StreamExt}; in peekable()
8 let peekable: Peekable<_> = stream::iter(vec![1u8, 2, 3]).peekable(); in peekable()
|
| D | auto_traits.rs | 1413 assert_impl!(Peekable<SendStream<()>>: Send);
1414 assert_not_impl!(Peekable<SendStream>: Send);
1415 assert_not_impl!(Peekable<LocalStream>: Send);
1416 assert_impl!(Peekable<SyncStream<()>>: Sync);
1417 assert_not_impl!(Peekable<SyncStream>: Sync);
1418 assert_not_impl!(Peekable<LocalStream>: Sync);
1419 assert_impl!(Peekable<UnpinStream>: Unpin);
1420 assert_not_impl!(Peekable<PinnedStream>: Unpin);
|
| /external/rust/crates/proc-macro-error-attr/src/ |
| D | parse.rs | 4 use std::iter::Peekable;
28 input: &mut Peekable<impl Iterator<Item = TokenTree>>, in parse_next_attr()
59 fn parse_signature(input: &mut Peekable<impl Iterator<Item = TokenTree>>) -> Vec<TokenTree> { in parse_signature()
|
| /external/rust/crates/itertools/src/ |
| D | with_position.rs | 1 use std::iter::{Fuse,Peekable};
13 peekable: Peekable<Fuse<I>>,
|
| D | peeking_take_while.rs | 1 use std::iter::Peekable;
22 impl<I> PeekingNext for Peekable<I> implementation
|
| /external/rust/crates/paste/src/ |
| D | segment.rs | 3 use std::iter::Peekable;
21 pub(crate) fn parse(tokens: &mut Peekable<token_stream::IntoIter>) -> Result<Vec<Segment>> { in parse()
|
| /external/rust/crates/futures-util/src/stream/ |
| D | mod.rs | 22 Fuse, Inspect, Map, Next, Peek, Peekable, Scan, SelectNextSome, Skip, SkipWhile, StreamExt,
|
| /external/rust/crates/itertools/src/adaptors/ |
| D | mod.rs | 18 use std::iter::{Fuse, Peekable, FromIterator};
512 a: Peekable<I>,
513 b: Peekable<J>,
548 Peekable<I>: Clone,
549 Peekable<J>: Clone,
|
| /external/rust/crates/futures/tests_disabled/ |
| D | stream.rs | 3 use futures::stream::{empty, iter_ok, poll_fn, Peekable};
284 inner: Peekable<Box<Stream<Item = i32, Error =u32> + Send>> in peek()
|
| /external/rust/crates/fallible-iterator/src/ |
| D | lib.rs | 297 fn peekable(self) -> Peekable<Self> in peekable()
301 Peekable { in peekable()
2184 pub struct Peekable<I: FallibleIterator> {
2189 impl<I> Peekable<I> impl
2204 impl<I> FallibleIterator for Peekable<I>
|
| /external/rust/crates/clap/src/app/ |
| D | parser.rs | 9 use std::iter::Peekable;
886 it: &mut Peekable<I>, in get_matches_with()
1328 it: &mut Peekable<I>, in parse_subcommand()
1618 it: &mut Peekable<I>, in parse_long_arg()
|
| /external/rust/crates/csv/src/ |
| D | deserializer.rs | 152 it: iter::Peekable<StringRecordIter<'r>>,
236 it: iter::Peekable<ByteRecordIter<'r>>,
|