Struct fluvio_socket::FluvioStream [−][src]
pub struct FluvioStream(_);
Expand description
inner flv stream which is generic over stream
Implementations
impl FluvioStream
[src]
impl FluvioStream
[src]pub fn new(stream: BoxReadConnection) -> Self
[src]
pub fn get_mut_tcp_stream(
&mut self
) -> &mut FramedRead<Compat<BoxReadConnection>, FluvioCodec>
[src]
&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,
[src]
pub fn request_stream<R>(
&mut self
) -> impl Stream<Item = Result<RequestMessage<R>, FlvSocketError>> + '_ where
RequestMessage<R>: FluvioDecoder + Debug,
[src]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,
[src]
pub async fn next_request_item<R>(
&mut self
) -> Option<Result<RequestMessage<R>, FlvSocketError>> where
RequestMessage<R>: FluvioDecoder + Debug,
[src]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,
[src]
pub async fn next_response<R>(
&mut self,
req_msg: &RequestMessage<R>
) -> Result<ResponseMessage<R::Response>, FlvSocketError> where
R: Request,
[src]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,
[src]
pub fn api_stream<R, A>(
&mut self
) -> impl Stream<Item = Result<R, FlvSocketError>> + '_ where
R: ApiMessage<ApiKey = A>,
A: FluvioDecoder + Debug,
[src]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,
[src]
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,
[src]
&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
[src]
impl From<FramedRead<Compat<Box<dyn ReadConnection + 'static, Global>>, FluvioCodec>> for FluvioStream
[src]fn from(stream: FramedRead<Compat<BoxReadConnection>, FluvioCodec>) -> Self
[src]
fn from(stream: FramedRead<Compat<BoxReadConnection>, FluvioCodec>) -> Self
[src]Performs the conversion.
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
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]pub fn borrow_mut(&mut self) -> &mut T
[src]
pub fn borrow_mut(&mut self) -> &mut T
[src]Mutably borrows from an owned value. Read more
impl<T> Instrument for T
[src]
impl<T> Instrument for T
[src]fn instrument(self, span: Span) -> Instrumented<Self>
[src]
fn instrument(self, span: Span) -> Instrumented<Self>
[src]Instruments this type with the provided Span
, returning an
Instrumented
wrapper. Read more
fn in_current_span(self) -> Instrumented<Self>
[src]
fn in_current_span(self) -> Instrumented<Self>
[src]impl<T> AsyncConnector for T where
T: Send + Sync,
[src]
T: Send + Sync,