Struct FluvioStream 

pub struct FluvioStream { /* private fields */ }

inner flv stream which is generic over stream

Implementations

impl FluvioStream

pub fn new(id: ConnectionFd, stream: BoxReadConnection) -> Self

pub fn get_mut_tcp_stream( &mut self, ) -> &mut FramedRead<Compat<BoxReadConnection>, FluvioCodec>

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

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

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

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)

pub async fn next_api_item<R, A>(&mut self) -> Option<Result<R, SocketError>>

where R: ApiMessage<ApiKey = A>, A: FluvioDecoder + Debug,

pub fn response_stream<R>( &mut self, req_msg: RequestMessage<R>, ) -> impl Stream<Item = R::Response> + '_

where R: Request,

Trait Implementations

impl Debug for FluvioStream

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.