Struct fluvio_socket::MultiplexerSocket

pub struct MultiplexerSocket { /* private fields */ }

Socket that can multiplex connections

Implementations

impl MultiplexerSocket

pub fn shared(socket: FluvioSocket) -> Arc<Self>

pub fn new(socket: FluvioSocket) -> Self

create new multiplexer socket, this always starts with correlation id of 1 correlation id of 0 means shared

pub fn set_stale(&self)

pub fn is_stale(&self) -> bool

pub async fn send_and_receive<R>( &self, req_msg: RequestMessage<R> ) -> Result<R::Response, SocketError>

where R: Request,

create socket to perform request and response

pub async fn send_async<R>( &self, req_msg: RequestMessage<R> ) -> Result<AsyncResponse<R>, SocketError>

where R: Request,

send request and get response asynchronously

pub async fn create_stream<R>( &self, req_msg: RequestMessage<R>, queue_len: usize ) -> Result<AsyncResponse<R>, SocketError>

where R: Request,

create stream response

Trait Implementations

impl Debug for MultiplexerSocket

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Drop for MultiplexerSocket

fn drop(&mut self)

Executes the destructor for this type.