Struct fluvio_socket::FluvioSocket [−][src]
pub struct FluvioSocket { /* fields omitted */ }
Expand description
Socket abstract that can send and receive fluvio objects
Implementations
pub async fn send<R>(
&mut self,
req_msg: &RequestMessage<R>
) -> Result<ResponseMessage<R::Response>, SocketError> where
R: Request,
pub async fn send<R>(
&mut self,
req_msg: &RequestMessage<R>
) -> Result<ResponseMessage<R::Response>, SocketError> where
R: Request,
as client, send request and wait for reply from server
pub fn from_stream(
write: BoxWriteConnection,
read: BoxReadConnection,
fd: ConnectionFd
) -> Self
pub async fn connect_with_connector(
addr: &str,
connector: &dyn TcpDomainConnector
) -> Result<Self, SocketError>
pub async fn connect_with_connector(
addr: &str,
connector: &dyn TcpDomainConnector
) -> Result<Self, SocketError>
connect to target address with connector
Trait Implementations
Performs the conversion.