Struct AptStream 

pub struct AptStream { /* private fields */ }

Asynchronous event stream for APT transport implementations.

Implementations

impl AptStream

pub fn new() -> Self

Create a new AsyncAptStream with stdin/stdout as the underlying streams.

pub fn with_input_stream( self, input_stream: Box<dyn AsyncBufRead + Unpin + Send>, ) -> Result<Self, Error>

Sets the input stream for reading APT requests.

Must only be set before any requests are processed (i.e. the first call to .next()), and should ultimately be routed to the stdin of the transport process that apt has spawned.

pub fn with_output_stream( self, output_stream: Box<dyn AsyncWrite + Unpin + Send>, ) -> Result<Self, Error>

Sets the output stream for all response writes.

Must only be set before any requests are processed (i.e. the first call to .next()), and should ultimately be routed to the stdout of the transport process that apt has spawned.

pub async fn next<'a>(&'a mut self) -> Result<Option<AptRequest<'a>>, Error>

Pulls the next APT request from the stream.