Struct PipelinedClient 

pub struct PipelinedClient { /* private fields */ }

Pipelined client for request pipelining

Implementations

impl PipelinedClient

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

Create a new pipelined client

pub fn connection(&self) -> &Arc<MultiplexedConnection>

Get the underlying connection

pub fn in_flight_count(&self) -> usize

Get current in-flight request count

pub fn can_send(&self) -> bool

Check if we can send more requests

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

Send a pipelined request Returns a future that resolves when the response is received

pub async fn send_batch( &self, requests: Vec<Bytes>, ) -> Result<Vec<Receiver<Result<Bytes, MultiplexError>>>, MultiplexError>

Send multiple requests in a batch

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

Process a response for a stream

pub async fn process_error( &self, stream_id: u16, error: MultiplexError, ) -> Result<(), MultiplexError>

Process an error for a stream

pub async fn cancel_all(&self)

Cancel all pending requests

pub async fn pending_count(&self) -> usize

Get pending request count