Struct fluvio_socket::MultiplexerSocket [−][src]
pub struct MultiplexerSocket { /* fields omitted */ }
Expand description
Socket that can multiplex connections
Implementations
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,
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,
pub async fn create_stream<R>(
&self,
req_msg: RequestMessage<R>,
queue_len: usize
) -> Result<AsyncResponse<R>, SocketError> where
R: Request,
create stream response