Searched refs:tx_task (Results 1 – 3 of 3) sorted by relevance
67 tx_task: Lock<Option<Waker>>, field117 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()
393 tx_task: Task, field523 tx_task: Task(UnsafeCell::new(MaybeUninit::uninit())), in channel()809 let will_notify = unsafe { inner.tx_task.will_wake(cx) }; in poll_closed()820 unsafe { inner.tx_task.drop_task() }; in poll_closed()828 inner.tx_task.set_task(cx); in poll_closed()1217 self.tx_task.with_task(Waker::wake_by_ref); in close()1257 self.tx_task.drop_task(); in drop()
233 let mut tx_task = task::spawn(()); in drops_tasks() localVariable236 assert_pending!(tx_task.enter(|cx, _| tx.poll_closed(cx))); in drops_tasks()242 assert_eq!(1, tx_task.waker_ref_count()); in drops_tasks()