/// as server, get next request from client
as server, get next request from client
as server get next request from client
pub async fn next_request_item<R>(&mut self) -> Option<Result<RequestMessage<R>, KfSocketError>>
    where
        RequestMessage<R>: KfDecoder + Debug,
    {
        let mut stream = self.request_stream();
        stream.next().await
    }
pub async fn next_request_item < R > ( & mut self ) -> Option < Result < RequestMessage < R > , KfSocketError > > where RequestMessage < R > : KfDecoder + Debug , { let mut stream = self . request_stream ( ) ; stream . next ( ) . await }
as server, get next request from client
as server get next request from client
&mut self