Searched refs:try_recv (Results 1 – 11 of 11) sorted by relevance
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| H A D | mpsc_test.rs | 69 assert_eq!(rx.try_recv(), Err(TryRecvError::Empty)); in sdv_unbounded_send_try_recv_test()
71 assert_eq!(rx.try_recv(), Ok(1)); in sdv_unbounded_send_try_recv_test()
73 assert_eq!(rx.try_recv(), Err(TryRecvError::Closed)); in sdv_unbounded_send_try_recv_test()
150 assert_eq!(rx.try_recv(), Err(TryRecvError::Empty)); in sdv_bounded_try_send_try_recv_test()
153 assert_eq!(rx.try_recv(), Ok(1)); in sdv_bounded_try_send_try_recv_test()
242 let _ = rx.try_recv(); in sdv_mpsc_len()
246 let _ = rx.try_recv(); in sdv_mpsc_len()
256 let _ = rx.try_recv(); in sdv_mpsc_len()
260 let _ = rx.try_recv(); in sdv_mpsc_len()
289 assert!(rx.try_recv().is_err()); in sdv_multi_send_recv_test()
[all …]
|
| H A D | udp_test.rs | 220 let len = connected_receiver.try_recv(&mut recv_buf[..]).unwrap(); in sdv_udp_try_recv()
258 let len = connected_receiver.try_recv(&mut recv_buf[..]).unwrap(); in sdv_udp_block_on_try_recv()
|
| H A D | uds_test.rs | 193 match client.try_recv(&mut data) { in sdv_uds_datagram_try_test()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/ |
| H A D | oneshot.rs | 326 pub fn try_recv(&mut self) -> Result<T, TryRecvError> { in try_recv() method
478 assert_eq!(rx.try_recv(), Err(TryRecvError::Empty)); in send_try_recv()
481 assert_eq!(rx.try_recv().unwrap(), "hello"); in send_try_recv()
482 assert_eq!(rx.try_recv(), Err(TryRecvError::Closed)); in send_try_recv()
529 let msg = rx.try_recv().unwrap(); in close_rx()
|
| /ohos5.0/base/request/request/services/src/manage/ |
| H A D | mod.rs | 298 manager.rx.try_recv().unwrap_err(); in ut_manager_reschedule()
301 manager.rx.try_recv().unwrap(), in ut_manager_reschedule()
307 manager.rx.try_recv().unwrap(), in ut_manager_reschedule()
313 manager.rx.try_recv().unwrap(), in ut_manager_reschedule()
317 manager.rx.try_recv().unwrap_err(); in ut_manager_reschedule()
321 manager.rx.try_recv().unwrap(), in ut_manager_reschedule()
327 manager.rx.try_recv().unwrap(), in ut_manager_reschedule()
333 manager.rx.try_recv().unwrap(), in ut_manager_reschedule()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/unbounded/ |
| H A D | mod.rs | 259 pub fn try_recv(&mut self) -> Result<T, TryRecvError> { in try_recv() method
260 self.channel.try_recv() in try_recv()
|
| H A D | queue.rs | 185 pub(crate) fn try_recv(&self) -> Result<T, TryRecvError> { in try_recv() method
220 match self.try_recv() { in poll_recv()
228 match self.try_recv() { in poll_recv()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/bounded/ |
| H A D | array.rs | 142 pub(crate) fn try_recv(&self) -> Result<T, TryRecvError> { in try_recv() method
169 match self.try_recv() { in poll_recv()
177 match self.try_recv() { in poll_recv()
|
| H A D | mod.rs | 377 pub fn try_recv(&mut self) -> Result<T, TryRecvError> { in try_recv() method
378 self.channel.try_recv() in try_recv()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/unix/ |
| H A D | datagram.rs | 168 pub fn try_recv(&self, buf: &mut [u8]) -> Result<usize> { in try_recv() method
550 match client.try_recv(&mut data) { in ut_uds_datagram_try_test()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/ |
| H A D | udp.rs | 1122 pub fn try_recv(&self, buf: &mut [u8]) -> io::Result<usize> { in try_recv() method
|