Struct fluvio_socket::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.