Struct fluvio_socket::FluvioStream
source · pub struct FluvioStream { /* private fields */ }Expand description
inner flv stream which is generic over stream
Implementations§
source§impl FluvioStream
impl FluvioStream
pub fn new(id: ConnectionFd, stream: BoxReadConnection) -> Self
pub fn get_mut_tcp_stream( &mut self ) -> &mut FramedRead<Compat<BoxReadConnection>, FluvioCodec>
sourcepub fn request_stream<R>(
&mut self
) -> impl Stream<Item = Result<RequestMessage<R>, SocketError>> + '_where
RequestMessage<R>: FluvioDecoder + Debug,
pub fn request_stream<R>( &mut self ) -> impl Stream<Item = Result<RequestMessage<R>, SocketError>> + '_where RequestMessage<R>: FluvioDecoder + Debug,
as server, get stream of request coming from client
sourcepub async fn next_request_item<R>(
&mut self
) -> Option<Result<RequestMessage<R>, SocketError>>where
RequestMessage<R>: FluvioDecoder + Debug,
pub async fn next_request_item<R>( &mut self ) -> Option<Result<RequestMessage<R>, SocketError>>where RequestMessage<R>: FluvioDecoder + Debug,
as server, get next request from client
sourcepub async fn next_response<R>(
&mut self,
req_msg: &RequestMessage<R>
) -> Result<ResponseMessage<R::Response>, SocketError>where
R: Request,
pub async fn next_response<R>( &mut self, req_msg: &RequestMessage<R> ) -> Result<ResponseMessage<R::Response>, SocketError>where R: Request,
as client, get next response from server
sourcepub fn api_stream<R, A>(
&mut self
) -> impl Stream<Item = Result<R, SocketError>> + '_where
R: ApiMessage<ApiKey = A>,
A: FluvioDecoder + Debug,
pub fn api_stream<R, A>( &mut self ) -> impl Stream<Item = Result<R, SocketError>> + '_where R: ApiMessage<ApiKey = A>, A: FluvioDecoder + Debug,
as server, get api request (PublicRequest, InternalRequest, etc)