Struct RequestPipeline 

pub struct RequestPipeline { /* private fields */ }

Request pipeline for managing multiple concurrent requests

Implementations

impl RequestPipeline

pub fn new( connection: Arc<MultiplexedConnection>, max_in_flight: usize, buffer_size: usize, ) -> Self

Create a new request pipeline

pub fn client(&self) -> &Arc<PipelinedClient>

Get the pipelined client

pub async fn submit( &self, data: Bytes, ) -> Result<Receiver<Result<Bytes, MultiplexError>>, MultiplexError>

Submit a request to the pipeline

pub async fn process_incoming( &self, stream_id: u16, data: Bytes, ) -> Result<(), MultiplexError>

Process incoming responses This should be called in a loop to handle responses

pub fn in_flight_count(&self) -> usize

Get current in-flight count

pub fn can_accept(&self) -> bool

Check if pipeline can accept more requests