| /dports/multimedia/librespot/librespot-0.1.3/cargo-crates/relay-0.1.1/src/ |
| H A D | lib.rs | 40 tx_task: None, in channel()
82 borrow.tx_task.take(); in drop()
132 if let Some(task) = borrow.tx_task.take() { in recv_inner()
154 let tx_task = { in drop() localVariable
158 borrow.tx_task.take() in drop()
160 if let Some(task) = tx_task { in drop()
187 self.tx.as_ref().unwrap().inner.borrow_mut().tx_task = Some(task::current()); in poll()
206 tx_task: Option<Task>, field
|
| /dports/audio/spotifyd/spotifyd-0.3.0/cargo-crates/relay-0.1.1/src/ |
| H A D | lib.rs | 40 tx_task: None, in channel()
82 borrow.tx_task.take(); in drop()
132 if let Some(task) = borrow.tx_task.take() { in recv_inner()
154 let tx_task = { in drop() localVariable
158 borrow.tx_task.take() in drop()
160 if let Some(task) = tx_task { in drop()
187 self.tx.as_ref().unwrap().inner.borrow_mut().tx_task = Some(task::current()); in poll()
206 tx_task: Option<Task>, field
|
| /dports/multimedia/termplay/termplay-2.0.6/cargo-crates/futures-channel-0.3.1/src/ |
| H A D | oneshot.rs | 68 tx_task: Lock<Option<Waker>>, field
119 tx_task: Lock::new(None), in new()
179 match self.tx_task.try_lock() { in poll_canceled()
226 if let Some(mut slot) = self.tx_task.try_lock() { in drop_tx()
235 if let Some(mut handle) = self.tx_task.try_lock() { in close_rx()
321 if let Some(mut handle) = self.tx_task.try_lock() { in drop_rx()
|
| /dports/net/proby/proby-1.0.2/cargo-crates/futures-channel-preview-0.3.0-alpha.19/src/ |
| H A D | oneshot.rs | 68 tx_task: Lock<Option<Waker>>, field
119 tx_task: Lock::new(None), in new()
179 match self.tx_task.try_lock() { in poll_cancel()
226 if let Some(mut slot) = self.tx_task.try_lock() { in drop_tx()
235 if let Some(mut handle) = self.tx_task.try_lock() { in close_rx()
321 if let Some(mut handle) = self.tx_task.try_lock() { in drop_rx()
|
| /dports/games/abstreet/abstreet-0.2.9-49-g74aca40c0/cargo-crates/futures-channel-preview-0.3.0-alpha.19/src/ |
| H A D | oneshot.rs | 68 tx_task: Lock<Option<Waker>>, field
119 tx_task: Lock::new(None), in new()
179 match self.tx_task.try_lock() { in poll_cancel()
226 if let Some(mut slot) = self.tx_task.try_lock() { in drop_tx()
235 if let Some(mut handle) = self.tx_task.try_lock() { in close_rx()
321 if let Some(mut handle) = self.tx_task.try_lock() { in drop_rx()
|
| /dports/lang/spidermonkey78/firefox-78.9.0/third_party/rust/futures-channel/src/ |
| H A D | oneshot.rs | 68 tx_task: Lock<Option<Waker>>, field
119 tx_task: Lock::new(None), in new()
179 match self.tx_task.try_lock() { in poll_canceled()
226 if let Some(mut slot) = self.tx_task.try_lock() { in drop_tx()
235 if let Some(mut handle) = self.tx_task.try_lock() { in close_rx()
321 if let Some(mut handle) = self.tx_task.try_lock() { in drop_rx()
|
| /dports/audio/spotifyd/spotifyd-0.3.0/cargo-crates/futures-channel-0.3.4/src/ |
| H A D | oneshot.rs | 68 tx_task: Lock<Option<Waker>>, field
119 tx_task: Lock::new(None), in new()
179 match self.tx_task.try_lock() { in poll_canceled()
226 if let Some(mut slot) = self.tx_task.try_lock() { in drop_tx()
235 if let Some(mut handle) = self.tx_task.try_lock() { in close_rx()
321 if let Some(mut handle) = self.tx_task.try_lock() { in drop_rx()
|
| /dports/multimedia/librespot/librespot-0.1.3/cargo-crates/futures-channel-0.3.5/src/ |
| H A D | oneshot.rs | 68 tx_task: Lock<Option<Waker>>, field
120 tx_task: Lock::new(None), in new()
180 match self.tx_task.try_lock() { in poll_canceled()
227 if let Some(mut slot) = self.tx_task.try_lock() { in drop_tx()
236 if let Some(mut handle) = self.tx_task.try_lock() { in close_rx()
322 if let Some(mut handle) = self.tx_task.try_lock() { in drop_rx()
|
| /dports/devel/sccache/sccache-0.2.15/cargo-crates/futures-channel-0.3.9/src/ |
| H A D | oneshot.rs | 70 tx_task: Lock<Option<Waker>>, field
124 tx_task: Lock::new(None), in new()
184 match self.tx_task.try_lock() { in poll_canceled()
231 if let Some(mut slot) = self.tx_task.try_lock() { in drop_tx()
240 if let Some(mut handle) = self.tx_task.try_lock() { in close_rx()
326 if let Some(mut handle) = self.tx_task.try_lock() { in drop_rx()
|
| /dports/games/genact/genact-0.10.0/cargo-crates/futures-channel-0.3.5/src/ |
| H A D | oneshot.rs | 68 tx_task: Lock<Option<Waker>>, field
120 tx_task: Lock::new(None), in new()
180 match self.tx_task.try_lock() { in poll_canceled()
227 if let Some(mut slot) = self.tx_task.try_lock() { in drop_tx()
236 if let Some(mut handle) = self.tx_task.try_lock() { in close_rx()
322 if let Some(mut handle) = self.tx_task.try_lock() { in drop_rx()
|
| /dports/net-im/fractal/fractal-4.4.0/vendor/futures-channel/src/ |
| H A D | oneshot.rs | 68 tx_task: Lock<Option<Waker>>, field
120 tx_task: Lock::new(None), in new()
180 match self.tx_task.try_lock() { in poll_canceled()
227 if let Some(mut slot) = self.tx_task.try_lock() { in drop_tx()
236 if let Some(mut handle) = self.tx_task.try_lock() { in close_rx()
322 if let Some(mut handle) = self.tx_task.try_lock() { in drop_rx()
|
| /dports/www/rearx/rearx-0.1.4/cargo-crates/futures-channel-0.3.13/src/ |
| H A D | oneshot.rs | 70 tx_task: Lock<Option<Waker>>, field
124 tx_task: Lock::new(None), in new()
184 match self.tx_task.try_lock() { in poll_canceled()
231 if let Some(mut slot) = self.tx_task.try_lock() { in drop_tx()
240 if let Some(mut handle) = self.tx_task.try_lock() { in close_rx()
326 if let Some(mut handle) = self.tx_task.try_lock() { in drop_rx()
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/futures-channel-0.3.5/src/ |
| H A D | oneshot.rs | 68 tx_task: Lock<Option<Waker>>, field
120 tx_task: Lock::new(None), in new()
180 match self.tx_task.try_lock() { in poll_canceled()
227 if let Some(mut slot) = self.tx_task.try_lock() { in drop_tx()
236 if let Some(mut handle) = self.tx_task.try_lock() { in close_rx()
322 if let Some(mut handle) = self.tx_task.try_lock() { in drop_rx()
|
| /dports/security/rustscan/RustScan-2.0.1/cargo-crates/futures-channel-0.3.7/src/ |
| H A D | oneshot.rs | 70 tx_task: Lock<Option<Waker>>, field
124 tx_task: Lock::new(None), in new()
184 match self.tx_task.try_lock() { in poll_canceled()
231 if let Some(mut slot) = self.tx_task.try_lock() { in drop_tx()
240 if let Some(mut handle) = self.tx_task.try_lock() { in close_rx()
326 if let Some(mut handle) = self.tx_task.try_lock() { in drop_rx()
|
| /dports/security/cargo-audit/rustsec-cargo-audit-v0.15.2/cargo-audit/cargo-crates/futures-channel-0.3.14/src/ |
| H A D | oneshot.rs | 70 tx_task: Lock<Option<Waker>>, field
124 tx_task: Lock::new(None), in new()
184 match self.tx_task.try_lock() { in poll_canceled()
231 if let Some(mut slot) = self.tx_task.try_lock() { in drop_tx()
240 if let Some(mut handle) = self.tx_task.try_lock() { in close_rx()
326 if let Some(mut handle) = self.tx_task.try_lock() { in drop_rx()
|
| /dports/security/cargo-audit/rustsec-cargo-audit-v0.15.2/cargo-audit/cargo-crates/futures-channel-0.3.13/src/ |
| H A D | oneshot.rs | 70 tx_task: Lock<Option<Waker>>, field
124 tx_task: Lock::new(None), in new()
184 match self.tx_task.try_lock() { in poll_canceled()
231 if let Some(mut slot) = self.tx_task.try_lock() { in drop_tx()
240 if let Some(mut handle) = self.tx_task.try_lock() { in close_rx()
326 if let Some(mut handle) = self.tx_task.try_lock() { in drop_rx()
|
| /dports/www/castor/castor-0.8.16/cargo-crates/futures-channel-0.3.6/src/ |
| H A D | oneshot.rs | 70 tx_task: Lock<Option<Waker>>, field
124 tx_task: Lock::new(None), in new()
184 match self.tx_task.try_lock() { in poll_canceled()
231 if let Some(mut slot) = self.tx_task.try_lock() { in drop_tx()
240 if let Some(mut handle) = self.tx_task.try_lock() { in close_rx()
326 if let Some(mut handle) = self.tx_task.try_lock() { in drop_rx()
|
| /dports/net/proby/proby-1.0.2/cargo-crates/futures-channel-0.3.5/src/ |
| H A D | oneshot.rs | 68 tx_task: Lock<Option<Waker>>, field
120 tx_task: Lock::new(None), in new()
180 match self.tx_task.try_lock() { in poll_canceled()
227 if let Some(mut slot) = self.tx_task.try_lock() { in drop_tx()
236 if let Some(mut handle) = self.tx_task.try_lock() { in close_rx()
322 if let Some(mut handle) = self.tx_task.try_lock() { in drop_rx()
|
| /dports/games/abstreet/abstreet-0.2.9-49-g74aca40c0/cargo-crates/futures-channel-0.3.5/src/ |
| H A D | oneshot.rs | 68 tx_task: Lock<Option<Waker>>, field
120 tx_task: Lock::new(None), in new()
180 match self.tx_task.try_lock() { in poll_canceled()
227 if let Some(mut slot) = self.tx_task.try_lock() { in drop_tx()
236 if let Some(mut handle) = self.tx_task.try_lock() { in close_rx()
322 if let Some(mut handle) = self.tx_task.try_lock() { in drop_rx()
|
| /dports/lang/rust/rustc-1.58.1-src/vendor/futures-channel/src/ |
| H A D | oneshot.rs | 70 tx_task: Lock<Option<Waker>>, field
124 tx_task: Lock::new(None), in new()
184 match self.tx_task.try_lock() { in poll_canceled()
231 if let Some(mut slot) = self.tx_task.try_lock() { in drop_tx()
240 if let Some(mut handle) = self.tx_task.try_lock() { in close_rx()
326 if let Some(mut handle) = self.tx_task.try_lock() { in drop_rx()
|
| /dports/audio/spotify-tui/spotify-tui-0.25.0/cargo-crates/futures-channel-0.3.5/src/ |
| H A D | oneshot.rs | 68 tx_task: Lock<Option<Waker>>, field
120 tx_task: Lock::new(None), in new()
180 match self.tx_task.try_lock() { in poll_canceled()
227 if let Some(mut slot) = self.tx_task.try_lock() { in drop_tx()
236 if let Some(mut handle) = self.tx_task.try_lock() { in close_rx()
322 if let Some(mut handle) = self.tx_task.try_lock() { in drop_rx()
|
| /dports/sysutils/tealdeer/tealdeer-1.4.1/cargo-crates/futures-channel-0.3.5/src/ |
| H A D | oneshot.rs | 68 tx_task: Lock<Option<Waker>>, field
120 tx_task: Lock::new(None), in new()
180 match self.tx_task.try_lock() { in poll_canceled()
227 if let Some(mut slot) = self.tx_task.try_lock() { in drop_tx()
236 if let Some(mut handle) = self.tx_task.try_lock() { in close_rx()
322 if let Some(mut handle) = self.tx_task.try_lock() { in drop_rx()
|
| /dports/multimedia/neolink/neolink-cf54129/cargo-crates/futures-channel-0.3.16/src/ |
| H A D | oneshot.rs | 67 tx_task: Lock<Option<Waker>>, field
117 tx_task: Lock::new(None), in new()
177 match self.tx_task.try_lock() { in poll_canceled()
224 if let Some(mut slot) = self.tx_task.try_lock() { in drop_tx()
233 if let Some(mut handle) = self.tx_task.try_lock() { in close_rx()
322 if let Some(mut handle) = self.tx_task.try_lock() { in drop_rx()
|
| /dports/multimedia/gstreamer1-plugins-rust/gst-plugins-rs-d0466b3eee114207f851b37cae0015c0e718f021/cargo-crates/futures-channel-0.3.16/src/ |
| H A D | oneshot.rs | 67 tx_task: Lock<Option<Waker>>, field
117 tx_task: Lock::new(None), in new()
177 match self.tx_task.try_lock() { in poll_canceled()
224 if let Some(mut slot) = self.tx_task.try_lock() { in drop_tx()
233 if let Some(mut handle) = self.tx_task.try_lock() { in close_rx()
322 if let Some(mut handle) = self.tx_task.try_lock() { in drop_rx()
|
| /dports/security/vaultwarden/vaultwarden-1.23.1/cargo-crates/futures-channel-0.3.18/src/ |
| H A D | oneshot.rs | 67 tx_task: Lock<Option<Waker>>, field
117 tx_task: Lock::new(None), in new()
177 match self.tx_task.try_lock() { in poll_canceled()
224 if let Some(mut slot) = self.tx_task.try_lock() { in drop_tx()
233 if let Some(mut handle) = self.tx_task.try_lock() { in close_rx()
322 if let Some(mut handle) = self.tx_task.try_lock() { in drop_rx()
|