Struct fluvio_socket::MultiplexerSocket [−][src]
pub struct MultiplexerSocket { /* fields omitted */ }
Expand description
Socket that can multiplex connections
Implementations
impl MultiplexerSocket
[src]
impl MultiplexerSocket
[src]pub fn shared(socket: FluvioSocket) -> Arc<Self>
[src]
pub fn new(socket: FluvioSocket) -> Self
[src]
pub fn new(socket: FluvioSocket) -> Self
[src]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, FlvSocketError> where
R: Request,
[src]
pub async fn send_and_receive<R>(
&self,
req_msg: RequestMessage<R>
) -> Result<R::Response, FlvSocketError> where
R: Request,
[src]create socket to perform request and response
pub async fn create_stream<R>(
&self,
req_msg: RequestMessage<R>,
queue_len: usize
) -> Result<AsyncResponse<R>, FlvSocketError> where
R: Request,
[src]
pub async fn create_stream<R>(
&self,
req_msg: RequestMessage<R>,
queue_len: usize
) -> Result<AsyncResponse<R>, FlvSocketError> where
R: Request,
[src]create stream response
Trait Implementations
Auto Trait Implementations
impl !RefUnwindSafe for MultiplexerSocket
impl Send for MultiplexerSocket
impl Sync for MultiplexerSocket
impl Unpin for MultiplexerSocket
impl !UnwindSafe for MultiplexerSocket
Blanket Implementations
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]pub fn borrow_mut(&mut self) -> &mut T
[src]
pub fn borrow_mut(&mut self) -> &mut T
[src]Mutably borrows from an owned value. Read more
impl<T> Instrument for T
[src]
impl<T> Instrument for T
[src]fn instrument(self, span: Span) -> Instrumented<Self>
[src]
fn instrument(self, span: Span) -> Instrumented<Self>
[src]Instruments this type with the provided Span
, returning an
Instrumented
wrapper. Read more
fn in_current_span(self) -> Instrumented<Self>
[src]
fn in_current_span(self) -> Instrumented<Self>
[src]impl<T> AsyncConnector for T where
T: Send + Sync,
[src]
T: Send + Sync,