/// start_directory_waiters will spawn the futures in directory_waiters as abortables, and adds
/// the abort handles to the IncomingNamespace.
start_directory_waiters will spawn the futures in directory_waiters as abortables, and adds
the abort handles to the IncomingNamespace.
start_directory_waiters will spawn the futures in directory_waiters as abortables and adds the abort handles to the IncomingNamespace .
fn start_directory_waiters(
        &mut self,
        directory_waiters: Vec<FutureObj<'static, ()>>,
    ) -> Result<(), ModelError> {
        for waiter in directory_waiters {
            let (abort_handle, abort_registration) = AbortHandle::new_pair();
            self.dir_abort_handles.push(abort_handle);
            let future = Abortable::new(waiter, abort_registration);
            // The future for a directory waiter will only terminate once the directory channel is
            // first used, so we must start up a new task here to run the future instead of calling
            // await on it directly. This is wrapped in an async move {await!();}` block to drop
            // the unused return value.
            fasync::spawn(async move {
                let _ = await!(future);
            });
        }
        Ok(())
    }
fn start_directory_waiters ( & mut self , directory_waiters : Vec < FutureObj < ' static , ( ) > > , ) -> Result < ( ) , ModelError > { for waiter in directory_waiters { let ( abort_handle , abort_registration ) = AbortHandle :: new_pair ( ) ; self . dir_abort_handles . push ( abort_handle ) ; let future = Abortable :: new ( waiter , abort_registration ) ; // The future for a directory waiter will only terminate once the directory channel is // first used, so we must start up a new task here to run the future instead of calling // await on it directly. This is wrapped in an async move {await!();}` block to drop // the unused return value. fasync :: spawn ( async move { let _ = await ! ( future ) ; } ) ; } Ok ( ( ) ) }
start_directory_waiters will spawn the futures in directory_waiters as abortables, and adds
the abort handles to the IncomingNamespace.
start_directory_waiters will spawn the futures in directory_waiters as abortables and adds the abort handles to the IncomingNamespace .
&mut self
directory_waiters
Vec<FutureObj<'static, ()>>