Home
last modified time | relevance | path

Searched refs:try_poll_next (Results 1 – 17 of 17) sorted by relevance

/external/rust/crates/futures-util/src/stream/try_stream/
Dtry_flatten.rs61 if let Some(item) = ready!(s.try_poll_next(cx)?) { in poll_next()
66 } else if let Some(s) = ready!(this.stream.as_mut().try_poll_next(cx)?) { in poll_next()
Dtry_skip_while.rs74 return this.stream.try_poll_next(cx); in poll_next()
87 } else if let Some(item) = ready!(this.stream.as_mut().try_poll_next(cx)?) { in poll_next()
Dinto_stream.rs41 self.project().stream.try_poll_next(cx) in poll_next()
Dtry_concat.rs43 if let Some(x) = ready!(this.stream.as_mut().try_poll_next(cx)?) { in poll()
Dtry_collect.rs52 match ready!(this.stream.as_mut().try_poll_next(cx)?) { in poll()
Dtry_for_each.rs62 match ready!(this.stream.as_mut().try_poll_next(cx)?) { in poll()
Dtry_filter_map.rs77 } else if let Some(item) = ready!(this.stream.as_mut().try_poll_next(cx)?) { in poll_next()
Dand_then.rs66 } else if let Some(item) = ready!(this.stream.as_mut().try_poll_next(cx)?) { in poll_next()
Dtry_fold.rs83 let res = ready!(this.stream.as_mut().try_poll_next(cx)); in poll()
Dor_else.rs67 match ready!(this.stream.as_mut().try_poll_next(cx)) { in poll_next()
Dtry_filter.rs88 } else if let Some(item) = ready!(this.stream.as_mut().try_poll_next(cx)?) { in poll_next()
Dtry_for_each_concurrent.rs80 Some(stream) => stream.try_poll_next(cx), in poll()
Dtry_take_while.rs91 } else if let Some(item) = ready!(this.stream.as_mut().try_poll_next(cx)?) { in poll_next()
Dmod.rs936 Pin::new(self).try_poll_next(cx) in try_poll_next_unpin()
/external/rust/crates/futures-core/src/
Dstream.rs188 fn try_poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) in try_poll_next() method
198 fn try_poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) in try_poll_next() function
/external/rust/crates/futures-util/src/future/try_future/
Dtry_flatten.rs98 let output = ready!(f.try_poll_next(cx)); in poll_next()
/external/rust/crates/futures-util/src/compat/
Dcompat03as01.rs134 with_context(self, |inner, cx| match inner.try_poll_next(cx)? { in poll()