async fn run_manager(&mut self, mut stream: PropertyManagerRequestStream) -> Result<(), Error> {
        while let Some(PropertyManagerRequest::SetProfile { intl_profile, responder }) =
            await!(stream.try_next()).context("Error running property manager server")?
        {
            fx_log_verbose!("Received profile set request: {:#?}", &intl_profile);
            let changed = self.set_profile(intl_profile);
            responder.send().context("Error sending response")?;
            fx_log_verbose!("Sent profile set response");
            if changed {
                await!(self.notify_listeners());
            }
        }
        Ok(())
    }
/// Handle `PropertyManager` requests as an infinite stream.
Handle `PropertyManager` requests as an infinite stream.
Handle ` PropertyManager ` requests as an infinite stream .
async fn run_manager(&mut self, mut stream: PropertyManagerRequestStream) -> Result<(), Error> {
        while let Some(PropertyManagerRequest::SetProfile { intl_profile, responder }) =
            await!(stream.try_next()).context("Error running property manager server")?
        {
            fx_log_verbose!("Received profile set request: {:#?}", &intl_profile);
            let changed = self.set_profile(intl_profile);
            responder.send().context("Error sending response")?;
            fx_log_verbose!("Sent profile set response");
            if changed {
                await!(self.notify_listeners());
            }
        }
        Ok(())
    }
async fn run_manager ( & mut self , mut stream : PropertyManagerRequestStream ) -> Result < ( ) , Error > { while let Some ( PropertyManagerRequest :: SetProfile { intl_profile , responder } ) = await ! ( stream try_next ( ) ) . context ( " " ) ? { fx_log_verbose ! ( " " intl_profile ) ; let changed = self . set_profile ( intl_profile ) ; responder . send ( ) . context ( " " ) ? ; fx_log_verbose ! ( " " ) ; if changed { await ! ( self notify_listeners ( ) ) ; } } Ok ( ( ) ) }
Handle `PropertyManager` requests as an infinite stream.
Handle ` PropertyManager ` requests as an infinite stream .
&mut self
stream
PropertyManagerRequestStream
&mut self
stream
PropertyManagerRequestStream