pub async fn handle_requests_from_stream<'a>(
        &'a self,
        context: &'a AccountContext,
        mut stream: AccountRequestStream,
        cancel: TaskGroupCancel,
    ) -> Result<(), Error> {
        self.inspect.open_client_channels.add(1);
        scopeguard::defer!(self.inspect.open_client_channels.subtract(1));
        while let Some(result) = cancel_or(&cancel, stream.try_next()).await {
            if let Some(request) = result? {
                self.handle_request(context, request).await?;
            } else {
                break;
            }
        }
        Ok(())
    }
/// Asynchronously handles the supplied stream of `AccountRequest` messages.
Asynchronously handles the supplied stream of `AccountRequest` messages.
Asynchronously handles the supplied stream of ` AccountRequest ` messages .
pub async fn handle_requests_from_stream<'a>(
        &'a self,
        context: &'a AccountContext,
        mut stream: AccountRequestStream,
        cancel: TaskGroupCancel,
    ) -> Result<(), Error> {
        self.inspect.open_client_channels.add(1);
        scopeguard::defer!(self.inspect.open_client_channels.subtract(1));
        while let Some(result) = cancel_or(&cancel, stream.try_next()).await {
            if let Some(request) = result? {
                self.handle_request(context, request).await?;
            } else {
                break;
            }
        }
        Ok(())
    }
pub async fn handle_requests_from_stream < ' a > ( & ' a self , context : & ' a AccountContext , mut stream : AccountRequestStream , cancel : TaskGroupCancel , ) -> Result < ( ) , Error > { self . inspect . open_client_channels . add ( 1 ) ; scopeguard :: defer ! ( self inspect open_client_channels subtract ( 1 ) ) ; while let Some ( result ) = cancel_or ( & cancel , stream . try_next ( ) ) . await { if let Some ( request ) = result ? { self . handle_request ( context , request ) . await ? ; } else { break ; } } Ok ( ( ) ) }
Asynchronously handles the supplied stream of `AccountRequest` messages.
Asynchronously handles the supplied stream of ` AccountRequest ` messages .
&'a self
context
&'a AccountContext
stream
AccountRequestStream
cancel
TaskGroupCancel
&'a self
context
&'a AccountContext
stream
AccountRequestStream
cancel
TaskGroupCancel