Home
last modified time | relevance | path

Searched refs:try_recv (Results 1 - 9 of 9) sorted by relevance

/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/
H A Dmpsc_test.rs69 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()
155 assert_eq!(rx.try_recv(), Err(TryRecvError::Closed)); 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()
[all...]
H A Duds_test.rs71 /// 3. Client receive message with `readable()` and `try_recv()`.
91 match client.try_recv(&mut data) { in sdv_uds_datagram_try_test()
H A Dudp_test.rs190 /// SDV test cases for try_send and try_recv
220 let len = connected_receiver.try_recv(&mut recv_buf[..]).unwrap(); in sdv_udp_try_recv()
227 /// SDV test cases for blocking on try_send and try_recv
258 let len = connected_receiver.try_recv(&mut recv_buf[..]).unwrap(); in sdv_udp_block_on_try_recv()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/
H A Doneshot.rs289 /// `try_recv` before a value is sent, then after.
296 /// match rx.try_recv() {
304 /// match rx.try_recv() {
311 /// `try_recv` when the sender dropped before sending a value
320 /// match rx.try_recv() {
326 pub fn try_recv(&mut self) -> Result<T, TryRecvError> { in try_recv() functions
345 /// [`try_recv`]: Receiver::try_recv
371 /// let msg = rx.try_recv().unwrap();
468 /// UT test cases for `send()` and `try_recv()` in fmt()
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/unbounded/
H A Dmod.rs71 /// assert!(rx.try_recv().is_err());
120 /// assert_eq!(rx.try_recv().unwrap(), 1);
244 /// match rx.try_recv() {
249 /// match rx.try_recv() {
254 /// match rx.try_recv() {
259 pub fn try_recv(&mut self) -> Result<T, TryRecvError> { in try_recv() functions
260 self.channel.try_recv() in try_recv()
387 /// let msg = rx.try_recv().unwrap();
H A Dqueue.rs185 pub(crate) fn try_recv(&self) -> Result<T, TryRecvError> {
220 match self.try_recv() {
228 match self.try_recv() {
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/bounded/
H A Dmod.rs76 /// assert!(rx.try_recv().is_err());
144 /// match rx.try_recv() {
149 /// match rx.try_recv() {
362 /// match rx.try_recv() {
367 /// match rx.try_recv() {
372 /// match rx.try_recv() {
377 pub fn try_recv(&mut self) -> Result<T, TryRecvError> { in try_recv() functions
378 self.channel.try_recv() in try_recv()
510 /// let msg = rx.try_recv().unwrap();
H A Darray.rs142 pub(crate) fn try_recv(&self) -> Result<T, TryRecvError> {
169 match self.try_recv() {
177 match self.try_recv() {
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/unix/
H A Ddatagram.rs69 /// match stream.try_recv(&mut data) {
118 /// match stream.try_recv(&mut data) {
154 /// match stream.try_recv(&mut data) {
168 pub fn try_recv(&self, buf: &mut [u8]) -> Result<usize> { in try_recv() functions
523 /// 3. Client receive message with `readable()` and `try_recv()`.
543 match client.try_recv(&mut data) { in ut_uds_datagram_try_test()

Completed in 5 milliseconds