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>> + '_
pub fn request_stream<R>( &mut self ) -> impl Stream<Item = Result<RequestMessage<R>, SocketError>> + '_
as server, get stream of request coming from client
sourcepub async fn next_request_item<R>(
&mut self
) -> Option<Result<RequestMessage<R>, SocketError>>
pub async fn next_request_item<R>( &mut self ) -> Option<Result<RequestMessage<R>, SocketError>>
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>> + '_
pub fn api_stream<R, A>( &mut self ) -> impl Stream<Item = Result<R, SocketError>> + '_
as server, get api request (PublicRequest, InternalRequest, etc)
pub async fn next_api_item<R, A>(&mut self) -> Option<Result<R, SocketError>>
pub fn response_stream<R>(
&mut self,
req_msg: RequestMessage<R>
) -> impl Stream<Item = R::Response> + '_where
R: Request,
Trait Implementations§
Auto Trait Implementations§
impl !RefUnwindSafe for FluvioStream
impl Send for FluvioStream
impl Sync for FluvioStream
impl Unpin for FluvioStream
impl !UnwindSafe for FluvioStream
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more