Struct fluvio_socket::FluvioSink [−][src]
pub struct FluvioSink { /* fields omitted */ }
Implementations
pub fn get_mut_tcp_sink(
&mut self
) -> &mut FramedWrite<Compat<BoxWriteConnection>, FluvioCodec>
convert to shared sink
pub async fn send_request<R>(
&mut self,
req_msg: &RequestMessage<R>
) -> Result<(), SocketError> where
RequestMessage<R>: FlvEncoder + Default + Debug,
pub async fn send_request<R>(
&mut self,
req_msg: &RequestMessage<R>
) -> Result<(), SocketError> where
RequestMessage<R>: FlvEncoder + Default + Debug,
as client, send request to server
pub async fn send_response<P>(
&mut self,
resp_msg: &ResponseMessage<P>,
version: Version
) -> Result<(), SocketError> where
ResponseMessage<P>: FlvEncoder + Default + Debug,
pub async fn send_response<P>(
&mut self,
resp_msg: &ResponseMessage<P>,
version: Version
) -> Result<(), SocketError> where
ResponseMessage<P>: FlvEncoder + Default + Debug,
as server, send back response