Struct fluvio_socket::MultiplexerSocket

pub struct MultiplexerSocket { /* fields omitted */ }

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 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 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.