Home
last modified time | relevance | path

Searched refs:try_recv (Results 1 – 25 of 47) sorted by relevance

12

/external/rust/crates/crossbeam-channel/tests/
Dready.rs27 assert_eq!(r1.try_recv(), Ok(1)); in smoke1()
35 assert_eq!(r2.try_recv(), Ok(2)); in smoke1()
55 assert_eq!(r5.try_recv(), Ok(5)); in smoke2()
74 Ok(0) => assert_eq!(r1.try_recv(), Err(TryRecvError::Disconnected)), in disconnected()
86 Ok(0) => assert_eq!(r1.try_recv(), Err(TryRecvError::Disconnected)), in disconnected()
99 Ok(0) => assert_eq!(r2.try_recv(), Err(TryRecvError::Disconnected)), in disconnected()
122 Ok(0) => assert!(r1.try_recv().is_err()), in default()
131 Ok(0) => assert_eq!(r2.try_recv(), Ok(2)), in default()
163 Ok(1) => assert_eq!(r2.try_recv(), Ok(2)), in timeout()
183 Ok(0) => assert_eq!(r.try_recv(), Err(TryRecvError::Disconnected)), in timeout()
[all …]
Dtick.rs20 assert_eq!(r.try_recv(), Err(TryRecvError::Empty)); in fire()
23 let fired = r.try_recv().unwrap(); in fire()
31 assert_eq!(r.try_recv(), Err(TryRecvError::Empty)); in fire()
54 let t2 = r.try_recv().unwrap(); in intervals()
58 assert_eq!(r.try_recv(), Err(TryRecvError::Empty)); in intervals()
63 assert_eq!(r.try_recv(), Err(TryRecvError::Empty)); in intervals()
90 r.try_recv().unwrap(); in len_empty_full()
98 fn try_recv() { in try_recv() function
100 assert!(r.try_recv().is_err()); in try_recv()
103 assert!(r.try_recv().is_err()); in try_recv()
[all …]
Dafter.rs20 assert_eq!(r.try_recv(), Err(TryRecvError::Empty)); in fire()
23 let fired = r.try_recv().unwrap(); in fire()
31 assert_eq!(r.try_recv(), Err(TryRecvError::Empty)); in fire()
68 r.try_recv().unwrap(); in len_empty_full()
76 fn try_recv() { in try_recv() function
78 assert!(r.try_recv().is_err()); in try_recv()
81 assert!(r.try_recv().is_err()); in try_recv()
84 assert!(r.try_recv().is_ok()); in try_recv()
85 assert!(r.try_recv().is_err()); in try_recv()
88 assert!(r.try_recv().is_err()); in try_recv()
[all …]
Dnever.rs73 fn try_recv() { in try_recv() function
75 assert!(r.try_recv().is_err()); in try_recv()
78 assert!(r.try_recv().is_err()); in try_recv()
Dmpsc.rs78 pub fn try_recv(&self) -> Result<T, TryRecvError> { in try_recv() method
79 self.inner.try_recv().map_err(|err| match err { in try_recv()
131 self.inner.try_recv().ok() in next()
339 match rx.try_recv() { in stress_shared()
479 assert_eq!(rx.try_recv(), Err(TryRecvError::Empty)); in oneshot_single_thread_peek_data()
481 assert_eq!(rx.try_recv(), Ok(10)); in oneshot_single_thread_peek_data()
488 assert_eq!(rx.try_recv(), Err(TryRecvError::Disconnected)); in oneshot_single_thread_peek_close()
489 assert_eq!(rx.try_recv(), Err(TryRecvError::Disconnected)); in oneshot_single_thread_peek_close()
495 assert_eq!(rx.try_recv(), Err(TryRecvError::Empty)); in oneshot_single_thread_peek_open()
912 assert_eq!(rx1.try_recv(), Err(TryRecvError::Empty)); in try_recv_states()
[all …]
Dlist.rs23 assert_eq!(r.try_recv(), Ok(7)); in smoke()
28 assert_eq!(r.try_recv(), Err(TryRecvError::Empty)); in smoke()
70 fn try_recv() { in try_recv() function
75 assert_eq!(r.try_recv(), Err(TryRecvError::Empty)); in try_recv()
77 assert_eq!(r.try_recv(), Ok(7)); in try_recv()
79 assert_eq!(r.try_recv(), Err(TryRecvError::Disconnected)); in try_recv()
289 assert_eq!(r.try_recv(), Err(TryRecvError::Empty)); in mpmc()
434 r.try_recv().unwrap(); in linearizable()
Darray.rs23 assert_eq!(r.try_recv(), Ok(7)); in smoke()
28 assert_eq!(r.try_recv(), Err(TryRecvError::Empty)); in smoke()
81 fn try_recv() { in try_recv() function
86 assert_eq!(r.try_recv(), Err(TryRecvError::Empty)); in try_recv()
88 assert_eq!(r.try_recv(), Ok(7)); in try_recv()
90 assert_eq!(r.try_recv(), Err(TryRecvError::Disconnected)); in try_recv()
159 assert_eq!(r.try_recv(), Ok(1)); in try_send()
160 assert_eq!(r.try_recv(), Err(TryRecvError::Empty)); in try_send()
544 r.try_recv().unwrap(); in linearizable()
Dzero.rs23 assert_eq!(r.try_recv(), Err(TryRecvError::Empty)); in smoke()
59 fn try_recv() { in try_recv() function
64 assert_eq!(r.try_recv(), Err(TryRecvError::Empty)); in try_recv()
66 assert_eq!(r.try_recv(), Ok(7)); in try_recv()
68 assert_eq!(r.try_recv(), Err(TryRecvError::Disconnected)); in try_recv()
Dselect_macro.rs309 if let Ok(x) = r2.try_recv() { in loop_try()
346 assert_eq!(r3.try_recv(), Err(TryRecvError::Empty)); in cloning1()
404 assert_eq!(r.try_recv(), Err(TryRecvError::Disconnected)); in preflight2()
657 assert_eq!(r.try_recv(), Err(TryRecvError::Empty)); in matching()
679 assert_eq!(r.try_recv(), Err(TryRecvError::Empty)); in matching_with_leftover()
754 let _ = r2.try_recv(); in linearizable_default()
762 let _ = r1.try_recv(); in linearizable_default()
798 let _ = r2.try_recv(); in linearizable_timeout()
806 let _ = r1.try_recv(); in linearizable_timeout()
1212 fn try_recv() { in try_recv() function
Dselect.rs458 if let Ok(x) = r2.try_recv() { in loop_try()
515 assert!(r3.try_recv().is_err()); in cloning1()
592 assert_eq!(r.try_recv(), Err(TryRecvError::Disconnected)); in preflight2()
913 assert_eq!(r.try_recv(), Err(TryRecvError::Empty)); in matching()
940 assert_eq!(r.try_recv(), Err(TryRecvError::Empty)); in matching_with_leftover()
1036 let _ = r2.try_recv(); in linearizable_try()
1044 let _ = r1.try_recv(); in linearizable_try()
1088 let _ = r2.try_recv(); in linearizable_timeout()
1096 let _ = r1.try_recv(); in linearizable_timeout()
1236 assert_eq!(r.try_recv(), Err(TryRecvError::Empty)); in sync_and_clone()
[all …]
/external/rust/crates/tokio/tests/
Dsync_broadcast.rs15 match $e.try_recv() {
24 match $e.try_recv() {
241 let x = dbg!(rx2.try_recv()); in lagging_rx()
253 assert_lagged!(rx2.try_recv(), 1); in lagging_rx()
257 assert_lagged!(rx2.try_recv(), 1); in lagging_rx()
309 let _ = rx.try_recv(); in panic_in_clone()
381 assert_closed!(rx.try_recv()); in single_capacity_recvs_after_drop_1()
392 assert_lagged!(rx.try_recv(), 1); in single_capacity_recvs_after_drop_2()
394 assert_closed!(rx.try_recv()); in single_capacity_recvs_after_drop_2()
407 assert_closed!(rx.try_recv()); in dropping_sender_does_not_overwrite()
[all …]
Dsync_oneshot.rs153 let val = assert_ok!(rx.try_recv()); in explicit_close_try_recv()
168 assert_err!(rx.try_recv()); in explicit_close_try_recv()
179 assert_err!(rx.try_recv()); in close_try_recv_poll()
190 assert_eq!(17, rx.try_recv().unwrap()); in close_after_recv()
200 assert_eq!(17, rx.try_recv().unwrap()); in try_recv_after_completion()
201 assert_eq!(Err(TryRecvError::Closed), rx.try_recv()); in try_recv_after_completion()
/external/rust/crates/futures/tests/
Deventual.rs27 assert!(rx.try_recv().is_err()); in join2()
29 assert!(rx.try_recv().is_err()); in join2()
41 assert!(rx.try_recv().is_err()); in join3()
54 assert!(rx.try_recv().is_err()); in join4()
68 assert!(rx.try_recv().is_err()); in join5()
70 assert!(rx.try_recv().is_err()); in join5()
72 assert!(rx.try_recv().is_err()); in join5()
84 assert!(rx.try_recv().is_err()); in select1()
103 assert!(rx.try_recv().is_err()); in select2()
122 assert!(rx.try_recv().is_err()); in select3()
Deager_drop.rs85 assert_eq!(Err(mpsc::TryRecvError::Empty), rx2.try_recv()); in then_drops_eagerly()
109 assert_eq!(Err(mpsc::TryRecvError::Empty), rx2.try_recv()); in and_then_drops_eagerly()
133 assert_eq!(Err(mpsc::TryRecvError::Empty), rx2.try_recv()); in or_else_drops_eagerly()
Dbasic_combinators.rs24 assert!(rx.try_recv().is_err()); // Not started yet in basic_future_combinators()
94 assert!(rx.try_recv().is_err()); // Not started yet in basic_try_future_combinators()
/external/rust/crates/crossbeam-utils/tests/
Dwait_group.rs28 assert!(rx.try_recv().is_err()); in wait()
56 assert!(rx.try_recv().is_err()); in wait_and_drop()
62 rx.try_recv().unwrap(); in wait_and_drop()
/external/rust/crates/futures/tests_disabled/
Dall.rs147 assert!(brx.try_recv().is_err()); in select_cancels()
148 assert!(drx.try_recv().is_err()); in select_cancels()
198 assert!(rx.try_recv().is_err()); in join_cancels()
212 assert!(rx.try_recv().is_err()); in join_incomplete()
221 assert!(rx.try_recv().is_err()); in join_incomplete()
230 assert!(rx.try_recv().is_err()); in join_incomplete()
239 assert!(rx.try_recv().is_err()); in join_incomplete()
275 assert_eq!(rx.try_recv().err().unwrap(), TryRecvError::Empty); in select2()
291 assert_eq!(rx.try_recv().err().unwrap(), TryRecvError::Empty); in select2()
/external/rust/crates/crossbeam-channel/src/flavors/
Dtick.rs38 pub fn try_recv(&self) -> Result<Instant, TryRecvError> { in try_recv() method
124 match self.try_recv() { in try_select()
Dat.rs43 pub fn try_recv(&self) -> Result<Instant, TryRecvError> { in try_recv() method
154 match self.try_recv() { in try_select()
Dnever.rs32 pub fn try_recv(&self) -> Result<T, TryRecvError> { in try_recv() method
/external/rust/crates/futures-channel/src/
Doneshot.rs248 fn try_recv(&self) -> Result<Option<T>, Canceled> { in try_recv() method
448 pub fn try_recv(&mut self) -> Result<Option<T>, Canceled> { in try_recv() method
449 self.inner.try_recv() in try_recv()
/external/rust/crates/tokio/src/sync/mpsc/
Dchan.rs225 macro_rules! try_recv { in recv() macro
249 try_recv!(); in recv()
256 try_recv!(); in recv()
/external/rust/crates/crossbeam-channel/src/
Dchannel.rs747 pub fn try_recv(&self) -> Result<T, TryRecvError> { in try_recv() method
749 ReceiverFlavor::Array(chan) => chan.try_recv(), in try_recv()
750 ReceiverFlavor::List(chan) => chan.try_recv(), in try_recv()
751 ReceiverFlavor::Zero(chan) => chan.try_recv(), in try_recv()
753 let msg = chan.try_recv(); in try_recv()
761 let msg = chan.try_recv(); in try_recv()
768 ReceiverFlavor::Never(chan) => chan.try_recv(), in try_recv()
1277 self.receiver.try_recv().ok() in next()
/external/rust/crates/crossbeam-channel/examples/
Dmatching.rs69 if let Ok(name) = r.try_recv() { in main()
/external/rust/crates/async-task/examples/
Dspawn-local.rs42 if let Ok(val) = r.try_recv() { in run()

12