pub fn api_stream<R, A>(&mut self) -> impl Stream<Item = Result<R, KfSocketError>> + '_
    where
        R: KfRequestMessage<ApiKey = A>,
        A: KfDecoder + Debug,
    {
        (&mut self.0).map(|req_bytes_r| match req_bytes_r {
            Ok(req_bytes) => {
                trace!("received bytes from client len: {}", req_bytes.len());
                let mut src = Cursor::new(&req_bytes);
                R::decode_from(&mut src).map_err(|err| err.into())
            }
            Err(err) => Err(err.into()),
        })
    }
/// as server, get api request (PublicRequest, InternalRequest, etc)
as server, get api request (PublicRequest, InternalRequest, etc)
as server get api request ( PublicRequest InternalRequest etc )
pub fn api_stream<R, A>(&mut self) -> impl Stream<Item = Result<R, KfSocketError>> + '_
    where
        R: KfRequestMessage<ApiKey = A>,
        A: KfDecoder + Debug,
    {
        (&mut self.0).map(|req_bytes_r| match req_bytes_r {
            Ok(req_bytes) => {
                trace!("received bytes from client len: {}", req_bytes.len());
                let mut src = Cursor::new(&req_bytes);
                R::decode_from(&mut src).map_err(|err| err.into())
            }
            Err(err) => Err(err.into()),
        })
    }
pub fn api_stream < R , A > ( & mut self ) -> impl Stream < Item = Result < R , KfSocketError > > + ' _ where R : KfRequestMessage < ApiKey = A > , A : KfDecoder + Debug , { ( & mut self . 0 ) . map ( | req_bytes_r | match req_bytes_r { Ok ( req_bytes ) => { trace ! ( " " req_bytes len ( ) ) ; let mut src = Cursor :: new ( & req_bytes ) ; R :: decode_from ( & mut src ) . map_err ( | err | err . into ( ) ) } Err ( err ) => Err ( err . into ( ) ) , } ) }
as server, get api request (PublicRequest, InternalRequest, etc)
as server get api request ( PublicRequest InternalRequest etc )
&mut self
&mut self