Struct AccessoryWorker 

pub struct AccessoryWorker {
    pub child: Child,
    /* private fields */
}

Fields

child: Child

Implementations

impl AccessoryWorker

pub fn new(child: Child) -> Result<Self>

Adopt a child with piped stdin/stdout. Windows ownership also attaches a kill-on-close job so a dead parent cannot strand an exclusive device owner.

pub fn new_independent(child: Child) -> Result<Self>

COM imports own the private Regain worker, not vendor helpers it launches.

pub async fn request(&mut self, request: Value) -> Result<Value>

pub async fn collect_json_with_timeout<T: DeserializeOwned>( self, request: Value, deadline: Duration, ) -> Result<Collected<T>>

Release a one-shot worker’s stdin startup barrier only after ownership is attached, then collect bounded JSON and reap it. Consuming self makes timeout/cancellation terminal. Neither stdout nor diagnostics are logged.

pub async fn request_with_timeout( &mut self, request: Value, deadline: Duration, ) -> Result<Value>

pub async fn request_typed_with_timeout<T: DeserializeOwned>( &mut self, request: Value, deadline: Duration, ) -> Result<T>

Deserialize the inner reply directly from its frame. Typed protocols must reject duplicate fields before conversion to a generic JSON map.

pub async fn request_typed_with_stream<T, R, F>( &mut self, request: Value, deadline: Duration, body: F, ) -> Result<R>

where T: DeserializeOwned, F: for<'a> FnOnce(T, &'a mut BufReader<ChildStdout>) -> Pin<Box<dyn Future<Output = Result<R>> + Send + 'a>>,

One acknowledged frame followed by a caller-defined finite binary body. The same process/cancellation guard spans both; a rejected header, partial body, failed allocation, timeout or dropped future retires the stream. The callback must consume and validate the entire body before succeeding.

pub fn reset(&mut self)

Retire a stream whose outstanding request may have been cancelled.

pub async fn close(self)

Trait Implementations

impl Drop for AccessoryWorker

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.