Fix unwrap

This commit is contained in:
Jonathan Turner 2019-08-31 07:28:10 +12:00
parent 60bfa277d0
commit c3abb3b687

View File

@ -53,8 +53,7 @@ fn ps(args: CommandArgs, registry: &CommandRegistry) -> Result<OutputStream, She
pin_utils::pin_mut!(processes);
while let Some(res) = processes.next().await {
let (process, usage) = res.unwrap();
if let Ok((process, usage)) = res {
let mut dict = TaggedDictBuilder::new(Tag::unknown_origin(span));
dict.insert("pid", Value::int(process.pid()));
if let Ok(name) = process.name().await {
@ -66,6 +65,7 @@ fn ps(args: CommandArgs, registry: &CommandRegistry) -> Result<OutputStream, She
dict.insert("cpu", Value::float(usage.get::<ratio::percent>() as f64));
yield ReturnSuccess::value(dict.into_tagged_value());
}
}
};
Ok(stream.to_output_stream())