Struct PipeTransportReceiver 

pub struct PipeTransportReceiver<R>
where
    R: AsyncRead + Unpin + Send,
{ /* private fields */ }

Receive-only part of PipeTransport

This struct only contains stdout and the message channel, allowing it to run the receive loop without needing stdin. This solves the deadlock issue by separating send and receive.

Implementations

impl<R> PipeTransportReceiver<R>

where R: AsyncRead + Unpin + Send,

pub async fn run(self) -> Result<()>

Run the message read loop

This continuously reads messages from stdout and sends them to the message channel.

For messages larger than 32KB, reads in chunks to reduce peak memory usage. Matches playwright-python’s chunked reading strategy.