| /external/rust/crates/futures-core/src/ |
| D | future.rs | 29 fn is_terminated(&self) -> bool; in is_terminated() method
33 fn is_terminated(&self) -> bool { in is_terminated() method
34 <F as FusedFuture>::is_terminated(&**self) in is_terminated()
43 fn is_terminated(&self) -> bool { in is_terminated() function
44 <P::Target as FusedFuture>::is_terminated(&**self) in is_terminated()
92 fn is_terminated(&self) -> bool { in is_terminated() method
93 <F as FusedFuture>::is_terminated(&**self) in is_terminated()
99 fn is_terminated(&self) -> bool { in is_terminated() method
100 <F as FusedFuture>::is_terminated(&**self) in is_terminated()
|
| D | stream.rs | 138 fn is_terminated(&self) -> bool; in is_terminated() method
142 fn is_terminated(&self) -> bool { in is_terminated() method
143 <F as FusedStream>::is_terminated(&**self) in is_terminated()
152 fn is_terminated(&self) -> bool { in is_terminated() function
153 <P::Target as FusedStream>::is_terminated(&**self) in is_terminated()
231 fn is_terminated(&self) -> bool { in is_terminated() method
232 <S as FusedStream>::is_terminated(&**self) in is_terminated()
|
| /external/rust/crates/futures/tests/ |
| D | stream_select_next_some.rs | 10 fn is_terminated() { in is_terminated() function
17 assert_eq!(select_next_some.is_terminated(), false); in is_terminated()
20 assert_eq!(select_next_some.is_terminated(), true); in is_terminated()
26 assert_eq!(select_next_some.is_terminated(), false); in is_terminated()
28 assert_eq!(select_next_some.is_terminated(), false); in is_terminated()
30 assert_eq!(select_next_some.is_terminated(), true); in is_terminated()
|
| D | stream_select_all.rs | 9 fn is_terminated() { in is_terminated() function
13 assert_eq!(tasks.is_terminated(), false); in is_terminated()
15 assert_eq!(tasks.is_terminated(), true); in is_terminated()
26 assert_eq!(tasks.is_terminated(), false); in is_terminated()
28 assert_eq!(tasks.is_terminated(), false); in is_terminated()
30 assert_eq!(tasks.is_terminated(), true); in is_terminated()
98 assert!(tasks.is_terminated()); in clear()
100 assert!(!tasks.is_terminated()); in clear()
|
| D | stream_futures_unordered.rs | 14 fn is_terminated() { in is_terminated() function
18 assert_eq!(tasks.is_terminated(), false); in is_terminated()
20 assert_eq!(tasks.is_terminated(), true); in is_terminated()
33 assert_eq!(tasks.is_terminated(), false); in is_terminated()
35 assert_eq!(tasks.is_terminated(), false); in is_terminated()
37 assert_eq!(tasks.is_terminated(), true); in is_terminated()
380 assert!(tasks.is_terminated()); in clear()
382 assert!(!tasks.is_terminated()); in clear()
|
| /external/rust/crates/futures-util/src/stream/stream/ |
| D | select_next_some.rs | 23 fn is_terminated(&self) -> bool { in is_terminated() method
24 self.stream.is_terminated() in is_terminated()
32 assert!(!self.stream.is_terminated(), "SelectNextSome polled after terminated"); in poll()
37 debug_assert!(self.stream.is_terminated()); in poll()
|
| D | peek.rs | 190 fn is_terminated(&self) -> bool { in is_terminated() method
191 self.peeked.is_none() && self.stream.is_terminated() in is_terminated()
248 fn is_terminated(&self) -> bool { in is_terminated() method
290 fn is_terminated(&self) -> bool { in is_terminated() method
337 fn is_terminated(&self) -> bool { in is_terminated() function
400 fn is_terminated(&self) -> bool { in is_terminated() function
401 self.inner.is_terminated() in is_terminated()
|
| D | buffer_unordered.rs | 105 fn is_terminated(&self) -> bool { in is_terminated() function
106 self.in_progress_queue.is_terminated() && self.stream.is_terminated() in is_terminated()
|
| D | next.rs | 23 fn is_terminated(&self) -> bool { in is_terminated() method
24 self.stream.is_terminated() in is_terminated()
|
| D | count.rs | 35 fn is_terminated(&self) -> bool { in is_terminated() method
36 self.stream.is_terminated() in is_terminated()
|
| D | zip.rs | 66 fn is_terminated(&self) -> bool { in is_terminated() function
67 self.stream1.is_terminated() && self.stream2.is_terminated() in is_terminated()
|
| D | catch_unwind.rs | 58 fn is_terminated(&self) -> bool { in is_terminated() method
59 self.caught_unwind || self.stream.is_terminated() in is_terminated()
|
| D | enumerate.rs | 29 fn is_terminated(&self) -> bool { in is_terminated() method
30 self.stream.is_terminated() in is_terminated()
|
| D | collect.rs | 35 fn is_terminated(&self) -> bool { in is_terminated() function
36 self.stream.is_terminated() in is_terminated()
|
| /external/rust/crates/futures-util/src/future/ |
| D | either.rs | 120 fn is_terminated(&self) -> bool { in is_terminated() function
122 Either::Left(x) => x.is_terminated(), in is_terminated()
123 Either::Right(x) => x.is_terminated(), in is_terminated()
155 fn is_terminated(&self) -> bool { in is_terminated() function
157 Either::Left(x) => x.is_terminated(), in is_terminated()
158 Either::Right(x) => x.is_terminated(), in is_terminated()
|
| D | option.rs | 52 fn is_terminated(&self) -> bool { in is_terminated() method
54 Some(x) => x.is_terminated(), in is_terminated()
|
| /external/rust/crates/futures-util/src/stream/futures_unordered/ |
| D | mod.rs | 61 is_terminated: AtomicBool, field
141 is_terminated: AtomicBool::new(false), in new()
180 self.is_terminated.store(false, Relaxed); in push()
410 *self.is_terminated.get_mut() = true; in poll_next()
566 self.is_terminated.store(false, Relaxed); in clear()
647 fn is_terminated(&self) -> bool { in is_terminated() method
648 self.is_terminated.load(Relaxed) in is_terminated()
|
| /external/rust/crates/futures-test/src/ |
| D | interleave_pending.rs | 86 fn is_terminated(&self) -> bool { in is_terminated() method
87 self.inner.is_terminated() in is_terminated()
104 fn is_terminated(&self) -> bool { in is_terminated() method
105 self.inner.is_terminated() in is_terminated()
|
| D | assert_unmoved.rs | 61 fn is_terminated(&self) -> bool { in is_terminated() method
62 self.inner.is_terminated() in is_terminated()
75 fn is_terminated(&self) -> bool { in is_terminated() method
76 self.inner.is_terminated() in is_terminated()
|
| /external/rust/crates/futures-util/src/future/try_future/ |
| D | into_future.rs | 24 fn is_terminated(&self) -> bool { in is_terminated() method
25 self.future.is_terminated() in is_terminated()
|
| /external/rust/crates/futures-test/src/future/ |
| D | pending_once.rs | 43 fn is_terminated(&self) -> bool { in is_terminated() method
44 self.polled_before && self.future.is_terminated() in is_terminated()
|
| /external/rust/crates/futures-util/src/stream/try_stream/ |
| D | try_next.rs | 23 fn is_terminated(&self) -> bool { in is_terminated() method
24 self.stream.is_terminated() in is_terminated()
|
| D | into_stream.rs | 28 fn is_terminated(&self) -> bool { in is_terminated() method
29 self.stream.is_terminated() in is_terminated()
|
| D | try_collect.rs | 31 fn is_terminated(&self) -> bool { in is_terminated() function
32 self.stream.is_terminated() in is_terminated()
|
| /external/rust/crates/futures-util/src/sink/ |
| D | err_into.rs | 54 fn is_terminated(&self) -> bool { in is_terminated() function
55 self.sink.is_terminated() in is_terminated()
|