| /external/rust/crates/futures-util/src/stream/try_stream/ |
| D | try_flatten.rs | 13 pub struct TryFlatten<St>
15 St: TryStream,
18 stream: St,
20 next: Option<St::Ok>,
24 impl<St> TryFlatten<St>
26 St: TryStream,
27 St::Ok: TryStream,
28 <St::Ok as TryStream>::Error: From<St::Error>,
30 pub(super) fn new(stream: St) -> Self { in new()
34 delegate_access_inner!(stream, St, ());
[all …]
|
| D | try_take_while.rs | 15 pub struct TryTakeWhile<St, Fut, F>
17 St: TryStream,
20 stream: St,
24 pending_item: Option<St::Ok>,
29 impl<St, Fut, F> fmt::Debug for TryTakeWhile<St, Fut, F>
31 St: TryStream + fmt::Debug,
32 St::Ok: fmt::Debug,
45 impl<St, Fut, F> TryTakeWhile<St, Fut, F>
47 St: TryStream,
48 F: FnMut(&St::Ok) -> Fut,
[all …]
|
| D | try_skip_while.rs | 15 pub struct TrySkipWhile<St, Fut, F> where St: TryStream {
17 stream: St,
21 pending_item: Option<St::Ok>,
26 impl<St, Fut, F> fmt::Debug for TrySkipWhile<St, Fut, F>
28 St: TryStream + fmt::Debug,
29 St::Ok: fmt::Debug,
42 impl<St, Fut, F> TrySkipWhile<St, Fut, F>
43 where St: TryStream,
44 F: FnMut(&St::Ok) -> Fut,
45 Fut: TryFuture<Ok = bool, Error = St::Error>,
[all …]
|
| D | and_then.rs | 14 pub struct AndThen<St, Fut, F> {
16 stream: St,
23 impl<St, Fut, F> fmt::Debug for AndThen<St, Fut, F>
25 St: fmt::Debug,
36 impl<St, Fut, F> AndThen<St, Fut, F>
37 where St: TryStream,
38 F: FnMut(St::Ok) -> Fut,
39 Fut: TryFuture<Error = St::Error>,
41 pub(super) fn new(stream: St, f: F) -> Self { in new() argument
45 delegate_access_inner!(stream, St, ());
[all …]
|
| D | or_else.rs | 14 pub struct OrElse<St, Fut, F> {
16 stream: St,
23 impl<St, Fut, F> fmt::Debug for OrElse<St, Fut, F>
25 St: fmt::Debug,
36 impl<St, Fut, F> OrElse<St, Fut, F>
37 where St: TryStream,
38 F: FnMut(St::Error) -> Fut,
39 Fut: TryFuture<Ok = St::Ok>,
41 pub(super) fn new(stream: St, f: F) -> Self { in new() argument
45 delegate_access_inner!(stream, St, ());
[all …]
|
| D | try_filter.rs | 15 pub struct TryFilter<St, Fut, F>
16 where St: TryStream
19 stream: St,
23 pending_item: Option<St::Ok>,
27 impl<St, Fut, F> fmt::Debug for TryFilter<St, Fut, F>
29 St: TryStream + fmt::Debug,
30 St::Ok: fmt::Debug,
42 impl<St, Fut, F> TryFilter<St, Fut, F>
43 where St: TryStream
45 pub(super) fn new(stream: St, f: F) -> Self { in new() argument
[all …]
|
| D | into_async_read.rs | 14 pub struct IntoAsyncRead<St>
16 St: TryStream<Error = Error> + Unpin,
17 St::Ok: AsRef<[u8]>,
19 stream: St,
20 state: ReadState<St::Ok>,
23 impl<St> Unpin for IntoAsyncRead<St>
25 St: TryStream<Error = Error> + Unpin,
26 St::Ok: AsRef<[u8]>,
37 impl<St> IntoAsyncRead<St>
39 St: TryStream<Error = Error> + Unpin,
[all …]
|
| D | try_concat.rs | 12 pub struct TryConcat<St: TryStream> {
14 stream: St,
15 accum: Option<St::Ok>,
19 impl<St> TryConcat<St>
21 St: TryStream,
22 St::Ok: Extend<<St::Ok as IntoIterator>::Item> + IntoIterator + Default,
24 pub(super) fn new(stream: St) -> Self { in new()
32 impl<St> Future for TryConcat<St>
34 St: TryStream,
35 St::Ok: Extend<<St::Ok as IntoIterator>::Item> + IntoIterator + Default,
[all …]
|
| D | try_fold.rs | 12 pub struct TryFold<St, Fut, T, F> {
14 stream: St,
22 impl<St, Fut, T, F> fmt::Debug for TryFold<St, Fut, T, F>
24 St: fmt::Debug,
37 impl<St, Fut, T, F> TryFold<St, Fut, T, F>
38 where St: TryStream,
39 F: FnMut(T, St::Ok) -> Fut,
40 Fut: TryFuture<Ok = T, Error = St::Error>,
42 pub(super) fn new(stream: St, f: F, t: T) -> Self { in new() argument
52 impl<St, Fut, T, F> FusedFuture for TryFold<St, Fut, T, F>
[all …]
|
| D | try_buffered.rs | 15 pub struct TryBuffered<St>
17 St: TryStream,
18 St::Ok: TryFuture,
21 stream: Fuse<IntoStream<St>>,
22 in_progress_queue: FuturesOrdered<IntoFuture<St::Ok>>,
27 impl<St> TryBuffered<St>
29 St: TryStream,
30 St::Ok: TryFuture,
32 pub(super) fn new(stream: St, n: usize) -> Self { in new() argument
40 delegate_access_inner!(stream, St, (. .));
[all …]
|
| D | try_for_each.rs | 12 pub struct TryForEach<St, Fut, F> {
14 stream: St,
21 impl<St, Fut, F> fmt::Debug for TryForEach<St, Fut, F>
23 St: fmt::Debug,
34 impl<St, Fut, F> TryForEach<St, Fut, F>
35 where St: TryStream,
36 F: FnMut(St::Ok) -> Fut,
37 Fut: TryFuture<Ok = (), Error = St::Error>,
39 pub(super) fn new(stream: St, f: F) -> Self { in new() argument
48 impl<St, Fut, F> Future for TryForEach<St, Fut, F>
[all …]
|
| D | try_filter_map.rs | 15 pub struct TryFilterMap<St, Fut, F> {
17 stream: St,
24 impl<St, Fut, F> fmt::Debug for TryFilterMap<St, Fut, F>
26 St: fmt::Debug,
37 impl<St, Fut, F> TryFilterMap<St, Fut, F> {
38 pub(super) fn new(stream: St, f: F) -> Self { in new() argument
42 delegate_access_inner!(stream, St, ());
45 impl<St, Fut, F, T> FusedStream for TryFilterMap<St, Fut, F>
46 where St: TryStream + FusedStream,
47 Fut: TryFuture<Ok = Option<T>, Error = St::Error>,
[all …]
|
| /external/rust/crates/itertools/src/ |
| D | sources.rs | 100 pub fn unfold<A, St, F>(initial_state: St, f: F) -> Unfold<St, F> in unfold() argument
101 where F: FnMut(&mut St) -> Option<A> in unfold()
109 impl<St, F> fmt::Debug for Unfold<St, F>
110 where St: fmt::Debug,
118 pub struct Unfold<St, F> {
121 pub state: St,
124 impl<A, St, F> Iterator for Unfold<St, F>
125 where F: FnMut(&mut St) -> Option<A>
142 pub struct Iterate<St, F> {
143 state: St,
[all …]
|
| /external/rust/crates/futures-util/src/stream/stream/ |
| D | map.rs | 15 pub struct Map<St, F> {
17 stream: St,
22 impl<St, F> fmt::Debug for Map<St, F>
24 St: fmt::Debug,
33 impl<St, F> Map<St, F> {
34 pub(crate) fn new(stream: St, f: F) -> Self { in new() argument
38 delegate_access_inner!(stream, St, ());
41 impl<St, F> FusedStream for Map<St, F>
42 where St: FusedStream,
43 F: FnMut1<St::Item>,
[all …]
|
| D | concat.rs | 12 pub struct Concat<St: Stream> {
14 stream: St,
15 accum: Option<St::Item>,
19 impl<St> Concat<St>
20 where St: Stream,
21 St::Item: Extend<<St::Item as IntoIterator>::Item> +
24 pub(super) fn new(stream: St) -> Self { in new()
32 impl<St> Future for Concat<St>
33 where St: Stream,
34 St::Item: Extend<<St::Item as IntoIterator>::Item> +
[all …]
|
| D | buffer_unordered.rs | 15 pub struct BufferUnordered<St>
17 St: Stream,
20 stream: Fuse<St>,
21 in_progress_queue: FuturesUnordered<St::Item>,
26 impl<St> fmt::Debug for BufferUnordered<St>
28 St: Stream + fmt::Debug,
39 impl<St> BufferUnordered<St>
41 St: Stream,
42 St::Item: Future,
44 pub(super) fn new(stream: St, n: usize) -> Self in new() argument
[all …]
|
| D | filter.rs | 15 pub struct Filter<St, Fut, F>
16 where St: Stream,
19 stream: St,
23 pending_item: Option<St::Item>,
27 impl<St, Fut, F> fmt::Debug for Filter<St, Fut, F>
29 St: Stream + fmt::Debug,
30 St::Item: fmt::Debug,
43 impl<St, Fut, F> Filter<St, Fut, F>
44 where St: Stream,
45 F: for<'a> FnMut1<&'a St::Item, Output=Fut>,
[all …]
|
| D | skip_while.rs | 14 pub struct SkipWhile<St, Fut, F> where St: Stream {
16 stream: St,
20 pending_item: Option<St::Item>,
25 impl<St, Fut, F> fmt::Debug for SkipWhile<St, Fut, F>
27 St: Stream + fmt::Debug,
28 St::Item: fmt::Debug,
41 impl<St, Fut, F> SkipWhile<St, Fut, F>
42 where St: Stream,
43 F: FnMut(&St::Item) -> Fut,
46 pub(super) fn new(stream: St, f: F) -> Self { in new() argument
[all …]
|
| D | peek.rs | 20 pub struct Peekable<St: Stream> {
22 stream: Fuse<St>,
23 peeked: Option<St::Item>,
27 impl<St: Stream> Peekable<St> {
28 pub(super) fn new(stream: St) -> Self { in new()
35 delegate_access_inner!(stream, St, (.));
39 pub fn peek(self: Pin<&mut Self>) -> Peek<'_, St> { in peek() argument
50 ) -> Poll<Option<&St::Item>> { in poll_peek()
65 impl<St: Stream> FusedStream for Peekable<St> {
108 pub struct Peek<'a, St: Stream> {
[all …]
|
| D | take_while.rs | 14 pub struct TakeWhile<St: Stream, Fut, F> {
16 stream: St,
20 pending_item: Option<St::Item>,
25 impl<St, Fut, F> fmt::Debug for TakeWhile<St, Fut, F>
27 St: Stream + fmt::Debug,
28 St::Item: fmt::Debug,
41 impl<St, Fut, F> TakeWhile<St, Fut, F>
42 where St: Stream,
43 F: FnMut(&St::Item) -> Fut,
46 pub(super) fn new(stream: St, f: F) -> Self { in new() argument
[all …]
|
| D | buffered.rs | 15 pub struct Buffered<St>
17 St: Stream,
18 St::Item: Future,
21 stream: Fuse<St>,
22 in_progress_queue: FuturesOrdered<St::Item>,
27 impl<St> fmt::Debug for Buffered<St>
29 St: Stream + fmt::Debug,
30 St::Item: Future,
41 impl<St> Buffered<St>
43 St: Stream,
[all …]
|
| D | flatten.rs | 13 pub struct Flatten<St, U> {
15 stream: St,
21 impl<St, U> Flatten<St, U> {
22 pub(super) fn new(stream: St) -> Self { in new()
26 delegate_access_inner!(stream, St, ());
29 impl<St> FusedStream for Flatten<St, St::Item>
31 St: FusedStream,
32 St::Item: Stream,
39 impl<St> Stream for Flatten<St, St::Item>
41 St: Stream,
[all …]
|
| D | for_each.rs | 12 pub struct ForEach<St, Fut, F> {
14 stream: St,
21 impl<St, Fut, F> fmt::Debug for ForEach<St, Fut, F>
23 St: fmt::Debug,
34 impl<St, Fut, F> ForEach<St, Fut, F>
35 where St: Stream,
36 F: FnMut(St::Item) -> Fut,
39 pub(super) fn new(stream: St, f: F) -> Self { in new() argument
48 impl<St, Fut, F> FusedFuture for ForEach<St, Fut, F>
49 where St: FusedStream,
[all …]
|
| D | into_future.rs | 11 pub struct StreamFuture<St> {
12 stream: Option<St>,
15 impl<St: Stream + Unpin> StreamFuture<St> {
16 pub(super) fn new(stream: St) -> Self { in new()
27 pub fn get_ref(&self) -> Option<&St> { in get_ref() argument
41 pub fn get_mut(&mut self) -> Option<&mut St> { in get_mut() argument
55 pub fn get_pin_mut(self: Pin<&mut Self>) -> Option<Pin<&mut St>> { in get_pin_mut() argument
68 pub fn into_inner(self) -> Option<St> { in into_inner() argument
73 impl<St: Stream + Unpin> FusedFuture for StreamFuture<St> {
79 impl<St: Stream + Unpin> Future for StreamFuture<St> {
[all …]
|
| /external/rust/crates/futures-util/src/stream/ |
| D | select_all.rs | 27 pub struct SelectAll<St> {
28 inner: FuturesUnordered<StreamFuture<St>>,
31 impl<St: Debug> Debug for SelectAll<St> {
37 impl<St: Stream + Unpin> SelectAll<St> {
64 pub fn push(&mut self, stream: St) { in push() argument
69 impl<St: Stream + Unpin> Default for SelectAll<St> {
75 impl<St: Stream + Unpin> Stream for SelectAll<St> {
76 type Item = St::Item;
100 impl<St: Stream + Unpin> FusedStream for SelectAll<St> {
131 impl<St: Stream + Unpin> FromIterator<St> for SelectAll<St> {
[all …]
|