Struct DeliveryThread 

pub(crate) struct DeliveryThread<'a> {
    pub(crate) ring: Arc<DeliveryRing>,
    pub(crate) inner: &'a Inner,
    pub(crate) join: Option<JoinHandle<()>>,
}

Owns the delivery thread for the lifetime of one capture run and tears it down on Drop, so teardown also happens when the capture thread UNWINDS.

Closing the ring is the delivery thread’s only wake-up: skip it and the thread parks in pop() forever, pinning the Python callback and leaving deliver_tid set to a tid the OS may hand to an unrelated thread (whose stop_capture would then be mistaken for a re-entrant self-stop and silently do nothing).

Fields

ring: Arc<DeliveryRing>

inner: &'a Inner

join: Option<JoinHandle<()>>

Trait Implementations

impl Drop for DeliveryThread<'_>

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.