Struct TransientChildStdio 

pub struct TransientChildStdio { /* private fields */ }

Transient child: one process per batch exchange.

write_request spawns and writes; try_read_response reads that child’s response and waits for exit. Overlapping batches each get their own child (limited usefulness vs persistent when max_in_flight is large).

Implementations

impl TransientChildStdio

pub fn new(command: Vec<String>, framer: FramerKind) -> Self

Trait Implementations

impl ExternalTransport for TransientChildStdio

fn write_request<'life0, 'life1, 'async_trait>( &'life0 self, batch_id: u64, items: &'life1 [Vec<u8>], kind: WireItemKind, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Write one framed request (header + item lines) for batch_id.

fn try_read_response<'life0, 'async_trait>( &'life0 self, batch_id: u64, ) -> Pin<Box<dyn Future<Output = Result<Option<WireResponse>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Await the response for a specific request batch_id.