Home
last modified time | relevance | path

Searched defs:poll (Results 1 – 25 of 279) sorted by relevance

12345678910>>...12

/external/rust/crates/tokio-test/tests/
Dmacros.rs31 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/
Dpoll.rs17 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
Dmod.rs10 mod poll; module
Dpending.rs35 fn poll(mut self: Pin<&mut Self>, _: &mut Context<'_>) -> Poll<Self::Output> { in poll() method
/external/rust/crates/futures-executor/benches/
Dthread_notify.rs22 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/
Dremote_handle.rs60 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
Dcatch_unwind.rs30 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() function
/external/rust/crates/futures-core/src/task/
Dmod.rs4 mod poll; module
/external/rust/crates/tokio/src/signal/
Dreusable_box.rs114 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/
Draw.rs14 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/
DTimedValueQueue.java86 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/
DChannelsLCStressTest.kt85 fun poll(): Any? = try { in <lambda>() method
170 fun poll(): Any? { in poll() method
/external/rust/crates/mio/examples/
Dudp_server.rs15 let mut poll = Poll::new()?; in main() localVariable
/external/rust/crates/futures/tests/
Dmacro_comma_support.rs17 fn poll() { in poll() function
/external/rust/crates/tokio/src/io/util/
Dflush.rs42 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() function
Dshutdown.rs42 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() function
Dcopy_buf.rs74 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/
DBlockingPoll.java34 public static void poll(BooleanSupplier func, long pollFrequency, long timeoutMillis) { in poll() method in BlockingPoll
/external/rust/crates/tokio-stream/src/stream_ext/
Dtry_next.rs35 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() method
Dnext.rs33 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() method
/external/rust/crates/futures-util/src/stream/try_stream/
Dtry_concat.rs39 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() function
/external/grpc-grpc/src/core/lib/iomgr/
Dpollset_custom.h28 void (*poll)(size_t timeout_ms); member
/external/rust/crates/tokio/src/io/
Dseek.rs40 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/
Dpollset_custom.h28 void (*poll)(size_t timeout_ms); member
/external/rust/crates/mio/src/
Dpoll.rs313 pub fn poll(&mut self, events: &mut Events, timeout: Option<Duration>) -> io::Result<()> { in poll() method
655 let poll = Poll::new().unwrap(); localVariable

12345678910>>...12