/// Asynchronously handles the supplied stream of `TokenManagerRequest` messages.
Asynchronously handles the supplied stream of `TokenManagerRequest` messages.
Asynchronously handles the supplied stream of ` TokenManagerRequest ` messages .
pub async fn handle_requests_from_stream<'a>(
        &'a self,
        context: &'a TokenManagerContext,
        mut stream: TokenManagerRequestStream,
    ) -> Result<(), failure::Error> {
        while let Some(req) = await!(stream.try_next())? {
            await!(self.handle_request(context, req))?;
        }
        Ok(())
    }
pub async fn handle_requests_from_stream < ' a > ( & ' a self , context : & ' a TokenManagerContext , mut stream : TokenManagerRequestStream , ) -> Result < ( ) , failure :: Error > { while let Some ( req ) = await ! ( stream try_next ( ) ) ? { await ! ( self handle_request ( context req ) ) ? ; } Ok ( ( ) ) }
Asynchronously handles the supplied stream of `TokenManagerRequest` messages.
Asynchronously handles the supplied stream of ` TokenManagerRequest ` messages .
&'a self
context
&'a TokenManagerContext
stream
TokenManagerRequestStream