| /external/rust/crates/async-stream/tests/ |
| D | stream.rs | 4 use futures_util::pin_mut;
12 pin_mut!(s); in noop_stream()
29 pin_mut!(s); in empty_stream()
56 pin_mut!(s); in fused()
112 pin_mut!(s); in consume_channel()
137 pin_mut!(s); in borrow_self()
151 pin_mut!(s); in stream_in_stream()
|
| /external/rust/crates/pin-utils/tests/ |
| D | stack_pin.rs | 3 use pin_utils::pin_mut;
10 pin_mut!(foo); in stack_pin()
15 pin_mut!( in stack_pin()
|
| D | projection.rs | 1 use pin_utils::{unsafe_pinned, unsafe_unpinned, pin_mut};
20 pin_mut!(foo); in projection()
|
| /external/crosvm/devices/src/virtio/vhost/user/ |
| D | worker.rs | 7 use futures::pin_mut;
59 pin_mut!(resample); in run()
70 pin_mut!(kill); in run()
|
| /external/rust/crates/async-stream/ |
| D | README.md | 24 use futures_util::pin_mut;
35 pin_mut!(s); // needed for iteration
49 use futures_util::pin_mut;
63 pin_mut!(s); // needed for iteration
77 use futures_util::pin_mut;
92 pin_mut!(input);
102 pin_mut!(s); // needed for iteration
|
| /external/rust/crates/futures/tests/ |
| D | stream_peekable.rs | 4 use futures::pin_mut; in peekable()
9 pin_mut!(peekable); in peekable()
|
| D | async_await_macros.rs | 3 use futures::{pending, pin_mut, poll}; in poll_and_pending()
9 pin_mut!(pending_once); in poll_and_pending()
17 use futures::{pin_mut, poll, join}; in join()
31 pin_mut!(fut); in join()
|
| D | sink.rs | 665 futures::pin_mut!(unfold); in sink_unfold()
|
| /external/rust/crates/async-stream/examples/ |
| D | tcp_accept.rs | 2 use futures_util::pin_mut;
16 pin_mut!(incoming); in main()
|
| /external/crosvm/devices/src/virtio/ |
| D | balloon.rs | 11 use futures::{channel::mpsc, pin_mut, StreamExt};
336 pin_mut!(inflate); in run_worker()
348 pin_mut!(deflate); in run_worker()
363 pin_mut!(stats); in run_worker()
367 pin_mut!(command); in run_worker()
371 pin_mut!(resample); in run_worker()
376 pin_mut!(kill); in run_worker()
|
| D | block_async.rs | 16 use futures::pin_mut;
531 pin_mut!(disk_flush); in run_worker()
535 pin_mut!(control); in run_worker()
539 pin_mut!(resample); in run_worker()
544 pin_mut!(kill); in run_worker()
|
| /external/rust/cxx/tests/ |
| D | test.rs | 231 assert_eq!(2021, unique_ptr.pin_mut().set(2021)); in test_c_method_calls()
235 assert_eq!(2021, *unique_ptr.pin_mut().getMut()); in test_c_method_calls()
236 assert_eq!(2022, unique_ptr.pin_mut().set_succeed(2022).unwrap()); in test_c_method_calls()
237 assert!(unique_ptr.pin_mut().get_fail().is_err()); in test_c_method_calls()
331 check!(e.pin_mut().c_take_opaque_mut_ref_method()); in test_extern_opaque()
343 assert_eq!(2023, c_unique.pin_mut().set_succeed(2023).unwrap()); in test_raw_ptr()
|
| /external/rust/crates/futures-executor/src/ |
| D | local_pool.rs | 7 use futures_util::pin_mut;
172 pin_mut!(future); in run_until()
316 pin_mut!(f); in block_on()
|
| /external/rust/crates/pin-utils/src/ |
| D | stack_pin.rs | 14 macro_rules! pin_mut { macro
|
| /external/libchromeos-rs/src/sync/ |
| D | blocking.rs | 11 use futures::pin_mut;
63 pin_mut!(f); in block_on()
|
| /external/crosvm/cros_async/src/sync/ |
| D | blocking.rs | 11 use futures::pin_mut;
63 pin_mut!(f); in block_on()
|
| /external/rust/crates/pin-utils/ |
| D | README.md | 22 use pin_utils::pin_mut; // And more...
|
| /external/rust/crates/futures-util/src/future/future/ |
| D | mod.rs | 21 use pin_utils::pin_mut;
604 pin_mut!(this); in now_or_never()
|
| /external/rust/crates/futures/src/ |
| D | lib.rs | 127 pub use futures_util::pin_mut;
|
| /external/crosvm/cros_async/src/ |
| D | fd_executor.rs | 23 use pin_utils::pin_mut;
317 pin_mut!(done); in run()
|
| D | uring_executor.rs | 70 use pin_utils::pin_mut;
353 pin_mut!(done); in run()
|
| /external/rust/cxx/src/ |
| D | unique_ptr.rs | 78 pub fn pin_mut(&mut self) -> Pin<&mut T> { in pin_mut() function
|
| /external/rust/crates/futures-channel/tests/ |
| D | mpsc.rs | 7 use futures::pin_mut;
32 pin_mut!(tx, rx); in send_recv_no_buffer()
|
| /external/rust/crates/futures-util/src/ |
| D | lib.rs | 34 pub use pin_utils::pin_mut;
|