Struct fluvio_socket::FluvioStream

pub struct FluvioStream(_);

inner flv stream which is generic over stream

Implementations

impl FluvioStream

pub fn new(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>, FlvSocketError>> + '_ 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>, FlvSocketError>> 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>, FlvSocketError> where
    R: Request, 

as client, get next response from server

pub fn api_stream<R, A>(
    &mut self
) -> impl Stream<Item = Result<R, FlvSocketError>> + '_ 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, FlvSocketError>> 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 From<FramedRead<Compat<Box<dyn ReadConnection + 'static, Global>>, FluvioCodec>> for FluvioStream

fn from(stream: FramedRead<Compat<BoxReadConnection>, FluvioCodec>) -> Self

Performs the conversion.