Struct AutoConsumer 

pub struct AutoConsumer { /* private fields */ }

Automatic consumer that runs in a background thread.

This provides a handle to a consumer running automatic event processing in a separate thread. It supports graceful shutdown and cleanup operations.

Implementations

impl AutoConsumer

pub fn shutdown(&self)

Signal the consumer to shutdown

pub fn join(&mut self)

Wait for the consumer thread to finish

pub fn shutdown_and_join(&mut self)

Shutdown and wait for the consumer thread to finish

pub fn is_running(&self) -> bool

Check if the consumer thread is still running

Trait Implementations

impl Drop for AutoConsumer

Automatic resource management for AutoConsumer.

Ensures proper cleanup when the consumer goes out of scope, which matters for embedded host runtimes (e.g. an FFI consumer wrapped by a garbage-collected language) that expect automatic resource management.

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.