Struct ComWorker 

pub struct ComWorker<C: ServerConnector + 'static> {
    pub sender: Sender<ComRequest>,
    pub handle: Option<JoinHandle<()>>,
    /* private fields */
}

Dedicated background worker thread manager handling COM MTA apartment thread affinity.

Dispatches requests received over an mpsc channel to Windows COM interfaces while maintaining a persistent connection pool and transparently evicting stale connection handles on RPC errors.

Fields

sender: Sender<ComRequest>

Channel sender for dispatching requests to the worker loop.

handle: Option<JoinHandle<()>>

Thread join handle for clean worker thread teardown.

Implementations

impl<C: ServerConnector + 'static> ComWorker<C>

pub fn closed() -> Self

Creates a dummy/closed ComWorker handle used when background worker initialization fails.

pub fn start(connector: Arc<C>) -> Result<Self, OpcError>

pub async fn send_request<F, R>(&self, req_builder: F) -> OpcResult<R>

where F: FnOnce(Sender<OpcResult<R>>) -> ComRequest,

Trait Implementations

impl<C: ServerConnector + 'static> Drop for ComWorker<C>

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.