/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 170 fun poll(): Any? { in poll() method
|
/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
|