| /aosp_15_r20/external/rust/android-crates-io/crates/tokio/src/sync/ |
| D | watch.rs | 308 pub struct RecvError(pub(super) ()); struct
312 impl fmt::Display for RecvError { implementation
318 impl Error for RecvError {} implementation
669 pub fn has_changed(&self) -> Result<bool, error::RecvError> { in has_changed()
746 pub async fn changed(&mut self) -> Result<(), error::RecvError> { in changed()
813 ) -> Result<Ref<'_, T>, error::RecvError> { in wait_for()
820 ) -> Result<Ref<'_, T>, error::RecvError> { in wait_for_inner()
885 ) -> Option<Result<(), error::RecvError>> { in maybe_changed()
907 ) -> Result<(), error::RecvError> { in changed_impl()
|
| D | oneshot.rs | 341 pub struct RecvError(pub(super) ()); struct
355 impl fmt::Display for RecvError { implementation
361 impl std::error::Error for RecvError {} implementation
1067 pub fn blocking_recv(self) -> Result<T, RecvError> { in blocking_recv() argument
1142 fn poll_recv(&self, cx: &mut Context<'_>) -> Poll<Result<T, RecvError>> { in poll_recv() argument
|
| D | broadcast.rs | 242 pub enum RecvError { enum
254 impl fmt::Display for RecvError { implementation
263 impl std::error::Error for RecvError {} implementation
1265 pub async fn recv(&mut self) -> Result<T, RecvError> { in recv() argument
1338 pub fn blocking_recv(&mut self) -> Result<T, RecvError> { in blocking_recv() argument
1398 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<T, RecvError>> { in poll() argument
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tokio/src/sync/mpsc/ |
| D | error.rs | 109 pub struct RecvError(()); struct
112 impl fmt::Display for RecvError { implementation
119 impl Error for RecvError {} implementation
|
| /aosp_15_r20/external/rust/android-crates-io/crates/oneshot-uniffi/src/ |
| D | errors.rs | 88 pub struct RecvError; struct
90 impl fmt::Display for RecvError { implementation
97 impl std::error::Error for RecvError {} implementation
|
| D | lib.rs | 451 pub fn recv(self) -> Result<T, RecvError> { in recv() argument
597 pub fn recv_ref(&self) -> Result<T, RecvError> { in recv_ref() argument
1140 unsafe fn write_async_waker(&self, cx: &mut task::Context<'_>) -> Poll<Result<T, RecvError>> { in write_async_waker() argument
|
| /aosp_15_r20/prebuilts/rust/linux-musl-x86/1.80.1/lib/rustlib/src/rust/library/std/src/sync/mpsc/ |
| H A D | mod.rs | 425 pub struct RecvError; struct
848 pub fn recv(&self) -> Result<T, RecvError> { in recv() argument
1164 impl fmt::Display for RecvError { implementation
1171 impl error::Error for RecvError { implementation
|
| /aosp_15_r20/prebuilts/rust/linux-x86/1.81.0/lib/rustlib/src/rust/library/std/src/sync/mpsc/ |
| H A D | mod.rs | 425 pub struct RecvError; struct
848 pub fn recv(&self) -> Result<T, RecvError> { in recv() argument
1164 impl fmt::Display for RecvError { implementation
1171 impl error::Error for RecvError { implementation
|
| /aosp_15_r20/prebuilts/rust/linux-x86/1.81.0.u1/lib/rustlib/src/rust/library/std/src/sync/mpsc/ |
| H A D | mod.rs | 425 pub struct RecvError; struct
848 pub fn recv(&self) -> Result<T, RecvError> { in recv() argument
1164 impl fmt::Display for RecvError { implementation
1171 impl error::Error for RecvError { implementation
|
| /aosp_15_r20/prebuilts/rust/linux-x86/1.80.1/lib/rustlib/src/rust/library/std/src/sync/mpsc/ |
| H A D | mod.rs | 425 pub struct RecvError; struct
848 pub fn recv(&self) -> Result<T, RecvError> { in recv() argument
1164 impl fmt::Display for RecvError { implementation
1171 impl error::Error for RecvError { implementation
|
| /aosp_15_r20/prebuilts/rust/linux-musl-x86/1.81.0/lib/rustlib/src/rust/library/std/src/sync/mpsc/ |
| H A D | mod.rs | 425 pub struct RecvError; struct
848 pub fn recv(&self) -> Result<T, RecvError> { in recv() argument
1164 impl fmt::Display for RecvError { implementation
1171 impl error::Error for RecvError { implementation
|
| /aosp_15_r20/external/rust/android-crates-io/crates/crossbeam-channel/src/ |
| D | err.rs | 54 pub struct RecvError; struct
282 impl fmt::Display for RecvError { implementation
288 impl error::Error for RecvError {} implementation
|
| D | select.rs | 1252 pub fn recv<T>(mut self, r: &Receiver<T>) -> Result<T, RecvError> { in recv() argument
|
| D | channel.rs | 812 pub fn recv(&self) -> Result<T, RecvError> { in recv() argument
|
| /aosp_15_r20/external/rust/crates/v4l2r/lib/src/decoder/ |
| D | stateful.rs | 322 RecvError(#[from] mpsc::RecvError), enumerator
334 RecvError(#[from] mpsc::RecvError), enumerator
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tokio-stream/src/wrappers/ |
| D | watch.rs | 80 ) -> (Result<(), RecvError>, Receiver<T>) { in make_future() argument
|
| D | broadcast.rs | 40 async fn make_future<T: Clone>(mut rx: Receiver<T>) -> (Result<T, RecvError>, Receiver<T>) { in make_future() argument
|
| /aosp_15_r20/prebuilts/rust/linux-musl-x86/1.81.0/lib/rustlib/src/rust/library/std/src/sync/mpmc/ |
| H A D | mod.rs | 304 pub fn recv(&self) -> Result<T, RecvError> { in recv() argument
|
| /aosp_15_r20/prebuilts/rust/linux-x86/1.81.0/lib/rustlib/src/rust/library/std/src/sync/mpmc/ |
| H A D | mod.rs | 304 pub fn recv(&self) -> Result<T, RecvError> { in recv() argument
|
| /aosp_15_r20/prebuilts/rust/linux-x86/1.81.0.u1/lib/rustlib/src/rust/library/std/src/sync/mpmc/ |
| H A D | mod.rs | 304 pub fn recv(&self) -> Result<T, RecvError> { in recv() argument
|
| /aosp_15_r20/prebuilts/rust/linux-x86/1.80.1/lib/rustlib/src/rust/library/std/src/sync/mpmc/ |
| H A D | mod.rs | 304 pub fn recv(&self) -> Result<T, RecvError> { in recv() argument
|
| /aosp_15_r20/prebuilts/rust/linux-musl-x86/1.80.1/lib/rustlib/src/rust/library/std/src/sync/mpmc/ |
| H A D | mod.rs | 304 pub fn recv(&self) -> Result<T, RecvError> { in recv() argument
|
| /aosp_15_r20/external/rust/android-crates-io/crates/crossbeam-channel/tests/ |
| D | mpsc.rs | 87 pub fn recv(&self) -> Result<T, RecvError> { in recv() argument
|