leyoda/cosmic-comp
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix: break from loop instead of unwrapping

Browse source
This commit is contained in:
Ashley Wulber 2026-03-19 11:53:57 -04:00 • committed by Ashley Wulber
parent 7fa5bd6b91
commit 1dab42ed56
1 changed files with 10 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

13
src/dbus/name_owners.rs
View file

@ -3,6 +3,7 @@
//! Compare to Mutter's `MetaDbusAccessChecker`
use futures_executor::ThreadPool;
use futures_util::stream::FusedStream;
use futures_util::{StreamExt, stream::FuturesUnordered};
use std::{
collections::{HashMap, HashSet},
@ -38,9 +39,15 @@ impl Inner {
/// Process all events so far on `stream`, and update `name_owners`.
fn update_if_needed(&mut self) {
let mut context = Context::from_waker(&self.waker);
while let Poll::Ready(val) = self.stream.poll_next_unpin(&mut context) {
let val = val.unwrap();
let args = val.args().unwrap();
while !self.stream.is_terminated()
&& let Poll::Ready(val) = self.stream.poll_next_unpin(&mut context)
{
let Some(val) = val else {
break;
};
let Ok(args) = val.args() else {
break;
};
match args.name {
BusName::Unique(name) => {
if args.new_owner.is_some() {