Struct BridgeDispatch 

pub struct BridgeDispatch { /* private fields */ }

Manages in-flight commands sent to the Chrome extension via native messaging.

Each command gets a UUID, is written to the native messaging stdout, and a oneshot receiver awaits the response from the extension.

Implementations

impl BridgeDispatch

pub fn new(writer: Stdout) -> Self

pub async fn dispatch( &self, tab_id: Option<u32>, method: &str, args: Value, ) -> Result<Value, String>

Send a command to the extension and await the response.

Errors

Returns an error if the write fails, the extension disconnects, or the command times out (30s).

pub async fn dispatch_cdp( &self, tab_id: u32, domain_method: &str, params: Option<Value>, ) -> Result<Value, String>

Send a CDP command to the extension.

Errors

Returns an error on write failure, disconnect, or timeout.

pub async fn on_response( &self, id: &str, data: Option<Value>, error: Option<String>, )

Called by the native messaging read loop when a response arrives.

pub async fn cancel_all(&self)

Drop all pending commands (e.g. on disconnect).

pub async fn pending_count(&self) -> usize

pub async fn pending_ids(&self) -> Vec<String>

Return the IDs of all currently pending commands (for testing).

pub async fn register_test_pending(&self, id: &str) -> Receiver<DispatchResult>

Insert a pending command directly and return the receiver (for testing).