| /external/rust/crates/tokio-test/tests/ |
| D | macros.rs | 31 let poll = ready(); in assert_ready() localVariable
41 let poll = pending(); in assert_ready_on_pending() localVariable
47 let poll = pending(); in assert_pending() localVariable
57 let poll = ready(); in assert_pending_on_ready() localVariable
63 let poll = ready_ok(); in assert_ready_ok() localVariable
73 let poll = ready_err(); in assert_ok_on_err() localVariable
79 let poll = ready_err(); in assert_ready_err() localVariable
89 let poll = ready_ok(); in assert_err_on_ok() localVariable
95 let poll = ready(); in assert_ready_eq() localVariable
105 let poll = ready_err(); in assert_eq_on_not_eq() localVariable
|
| /external/rust/crates/futures-util/src/async_await/ |
| D | poll.rs | 17 macro_rules! poll { macro
24 pub fn poll<F: Future + Unpin>(future: F) -> PollOnce<F> { in poll() function
36 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() method
|
| D | mod.rs | 10 mod poll; module
|
| D | pending.rs | 35 fn poll(mut self: Pin<&mut Self>, _: &mut Context<'_>) -> Poll<Self::Output> { in poll() method
|
| /external/rust/crates/futures-executor/benches/ |
| D | thread_notify.rs | 22 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in thread_yield_single_thread_one_wait() method
50 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in thread_yield_single_thread_many_wait() method
87 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in thread_yield_multi_thread() method
|
| /external/rust/crates/futures-util/src/future/future/ |
| D | remote_handle.rs | 60 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<T> { in poll() method
97 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<()> { in poll() method
|
| D | catch_unwind.rs | 30 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() function
|
| /external/rust/crates/futures-core/src/task/ |
| D | mod.rs | 4 mod poll; module
|
| /external/rust/crates/tokio/src/signal/ |
| D | reusable_box.rs | 114 pub(crate) fn poll(&mut self, cx: &mut Context<'_>) -> Poll<T> { in poll() method
123 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<T> { in poll() method
205 fn poll(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<u32> { in poll() method
|
| /external/rust/crates/tokio/src/runtime/task/ |
| D | raw.rs | 14 pub(super) poll: unsafe fn(NonNull<Header>), field
64 pub(super) fn poll(self) { in poll() method
102 unsafe fn poll<T: Future, S: Schedule>(ptr: NonNull<Header>) { in poll() function
|
| /external/exoplayer/tree/library/core/src/main/java/com/google/android/exoplayer2/util/ |
| D | TimedValueQueue.java | 86 public synchronized @Nullable V poll(long timestamp) { in poll() method in TimedValueQueue
101 private V poll(long timestamp, boolean onlyOlder) { in poll() method in TimedValueQueue
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/linearizability/ |
| D | ChannelsLCStressTest.kt | 85 fun poll(): Any? = try { in <lambda>() method in kotlinx.coroutines.linearizability.ChannelLCStressTestBase
170 fun poll(): Any? { in poll() method in SequentialIntChannelBase
|
| /external/rust/crates/mio/examples/ |
| D | udp_server.rs | 15 let mut poll = Poll::new()?; in main() localVariable
|
| /external/rust/crates/futures/tests/ |
| D | macro_comma_support.rs | 17 fn poll() { in poll() function
|
| /external/rust/crates/tokio/src/io/util/ |
| D | flush.rs | 42 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() function
|
| D | shutdown.rs | 42 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() function
|
| D | copy_buf.rs | 74 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() function
|
| /external/connectedappssdk/testing/sdk/src/main/java/com/google/android/enterprise/connectedapps/testing/ |
| D | BlockingPoll.java | 34 public static void poll(BooleanSupplier func, long pollFrequency, long timeoutMillis) { in poll() method in BlockingPoll
|
| /external/rust/crates/tokio-stream/src/stream_ext/ |
| D | try_next.rs | 35 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() method
|
| D | next.rs | 33 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() method
|
| /external/rust/crates/futures-util/src/stream/try_stream/ |
| D | try_concat.rs | 39 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() function
|
| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | pollset_custom.h | 28 void (*poll)(size_t timeout_ms); member
|
| /external/rust/crates/tokio/src/io/ |
| D | seek.rs | 40 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() function
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/ |
| D | pollset_custom.h | 28 void (*poll)(size_t timeout_ms); member
|
| /external/rust/crates/mio/src/ |
| D | poll.rs | 313 pub fn poll(&mut self, events: &mut Events, timeout: Option<Duration>) -> io::Result<()> { in poll() method
655 let poll = Poll::new().unwrap(); localVariable
|