| /external/rust/crates/crossbeam-channel/src/ |
| D | select.rs | 98 fn try_select(&self, token: &mut Token) -> bool; in try_select() method
123 fn try_select(&self, token: &mut Token) -> bool { in try_select() method
124 (**self).try_select(token) in try_select()
202 if handle.try_select(&mut token) { in run_select()
215 cx.try_select(Selected::Aborted).unwrap(); in run_select()
225 sel = match cx.try_select(Selected::Aborted) { in run_select()
271 if i == index_ready && handle.try_select(&mut token) { in run_select()
303 if handle.try_select(&mut token) { in run_select()
383 sel = match cx.try_select(Selected::Operation(oper)) { in run_ready()
446 pub fn try_select<'a>( in try_select() function
[all …]
|
| D | waker.rs | 78 pub fn try_select(&mut self) -> Option<Entry> { in try_select() method
89 let res = self.selectors[i].cx.try_select(sel); in try_select()
143 if entry.cx.try_select(Selected::Operation(entry.oper)).is_ok() { in notify()
153 if entry.cx.try_select(Selected::Disconnected).is_ok() { in disconnect()
225 inner.try_select(); in notify()
|
| D | channel.rs | 1336 fn try_select(&self, token: &mut Token) -> bool { in try_select() method
1338 SenderFlavor::Array(chan) => chan.sender().try_select(token), in try_select()
1339 SenderFlavor::List(chan) => chan.sender().try_select(token), in try_select()
1340 SenderFlavor::Zero(chan) => chan.sender().try_select(token), in try_select()
1398 fn try_select(&self, token: &mut Token) -> bool { in try_select() method
1400 ReceiverFlavor::Array(chan) => chan.receiver().try_select(token), in try_select()
1401 ReceiverFlavor::List(chan) => chan.receiver().try_select(token), in try_select()
1402 ReceiverFlavor::Zero(chan) => chan.receiver().try_select(token), in try_select()
1403 ReceiverFlavor::At(chan) => chan.try_select(token), in try_select()
1404 ReceiverFlavor::Tick(chan) => chan.try_select(token), in try_select()
[all …]
|
| D | context.rs | 92 pub fn try_select(&self, select: Selected) -> Result<(), Selected> { in try_select() method
169 return match self.try_select(Selected::Aborted) { in wait_until()
|
| D | lib.rs | 354 pub use crate::select::{select, select_timeout, try_select};
|
| D | select_macro.rs | 825 let _oper = $crate::internal::try_select(&mut $sel);
|
| /external/rust/crates/crossbeam-channel/src/flavors/ |
| D | zero.rs | 119 if let Some(operation) = inner.receivers.try_select() { in start_send()
148 if let Some(operation) = inner.senders.try_select() { in start_recv()
191 if let Some(operation) = inner.receivers.try_select() { in try_send()
211 if let Some(operation) = inner.receivers.try_select() { in send()
264 if let Some(operation) = inner.senders.try_select() { in try_recv()
281 if let Some(operation) = inner.senders.try_select() { in recv()
369 fn try_select(&self, token: &mut Token) -> bool { in try_select() method
419 fn try_select(&self, token: &mut Token) -> bool { in try_select() method
|
| D | never.rs | 76 fn try_select(&self, _token: &mut Token) -> bool { in try_select() method
95 self.try_select(token) in accept()
|
| D | array.rs | 376 let _ = cx.try_select(Selected::Aborted); in send()
436 let _ = cx.try_select(Selected::Aborted); in recv()
572 fn try_select(&self, token: &mut Token) -> bool { in try_select() method
590 self.try_select(token) in accept()
608 fn try_select(&self, token: &mut Token) -> bool { in try_select() method
626 self.try_select(token) in accept()
|
| D | tick.rs | 123 fn try_select(&self, token: &mut Token) -> bool { in try_select() method
152 self.try_select(token) in accept()
|
| D | at.rs | 153 fn try_select(&self, token: &mut Token) -> bool { in try_select() method
187 self.try_select(token) in accept()
|
| D | list.rs | 469 let _ = cx.try_select(Selected::Aborted); in recv()
606 fn try_select(&self, token: &mut Token) -> bool { in try_select() method
624 self.try_select(token) in accept()
642 fn try_select(&self, token: &mut Token) -> bool { in try_select() method
657 self.try_select(token) in accept()
|
| /external/rust/crates/futures-util/src/future/ |
| D | mod.rs | 100 mod try_select; module
101 pub use self::try_select::{try_select, TrySelect};
|
| D | try_select.rs | 50 pub fn try_select<A, B>(future1: A, future2: B) -> TrySelect<A, B> in try_select() function
|
| /external/rust/crates/futures/tests/ |
| D | eventual.rs | 83 run(future::try_select(p1, p2).map_ok(move |v| tx.send(v).unwrap())); in select1()
102 run(future::try_select(p1, p2).map_err(move |v| tx.send((1, v.into_inner().1)).unwrap())); in select2()
121 run(future::try_select(p1, p2).map_err(move |v| tx.send((1, v.into_inner().1)).unwrap())); in select3()
151 run(future::try_select(p1, p2).map_ok(move |_| tx3.send(()).unwrap())); in select4()
|
| D | futures_ordered.rs | 81 Box::new(future::try_select(b_rx, c_rx) in queue_never_unblocked()
|
| D | shared.rs | 68 let f = future::try_select(f1.map_err(|_| ()), rx2.map_err(|_| ())); in drop_on_one_task_ok()
|
| /external/rust/crates/crossbeam-channel/tests/ |
| D | select.rs | 142 let oper = sel.try_select(); in default()
153 let oper = sel.try_select(); in default()
167 let oper = sel.try_select(); in default()
178 let oper = sel.try_select(); in default()
185 let oper = sel.try_select(); in default()
245 let oper = sel.try_select(); in timeout()
266 let oper = sel.try_select(); in default_when_disconnected()
292 let oper = sel.try_select(); in default_when_disconnected()
320 let oper = sel.try_select(); in default_only()
424 let oper = sel.try_select(); in loop_try()
[all …]
|