diff options
author | Simon Wülker <simon.wuelker@arcor.de> | 2025-03-03 12:26:53 +0100 |
---|---|---|
committer | GitHub <noreply@github.com> | 2025-03-03 11:26:53 +0000 |
commit | 3d320fa96ae2ca95a720c454c47ee7827864c5af (patch) | |
tree | 1b7718d574cb9164d924b7571760d90d6d2099c4 /components/devtools/actors/timeline.rs | |
parent | 6300e820b4e3fbfcec260048f931528d4998d5e4 (diff) | |
download | servo-3d320fa96ae2ca95a720c454c47ee7827864c5af.tar.gz servo-3d320fa96ae2ca95a720c454c47ee7827864c5af.zip |
Update rustfmt to the 2024 style edition (#35764)
* Use 2024 style edition
Signed-off-by: Simon Wülker <simon.wuelker@arcor.de>
* Reformat all code
Signed-off-by: Simon Wülker <simon.wuelker@arcor.de>
---------
Signed-off-by: Simon Wülker <simon.wuelker@arcor.de>
Diffstat (limited to 'components/devtools/actors/timeline.rs')
-rw-r--r-- | components/devtools/actors/timeline.rs | 28 |
1 files changed, 15 insertions, 13 deletions
diff --git a/components/devtools/actors/timeline.rs b/components/devtools/actors/timeline.rs index 1a399bb8a5b..0ea9fbcd722 100644 --- a/components/devtools/actors/timeline.rs +++ b/components/devtools/actors/timeline.rs @@ -20,11 +20,11 @@ use ipc_channel::ipc::{self, IpcReceiver, IpcSender}; use serde::{Serialize, Serializer}; use serde_json::{Map, Value}; +use crate::StreamId; use crate::actor::{Actor, ActorMessageStatus, ActorRegistry}; use crate::actors::framerate::FramerateActor; use crate::actors::memory::{MemoryActor, TimelineMemoryReply}; use crate::protocol::JsonPacketStream; -use crate::StreamId; pub struct TimelineActor { name: String, @@ -163,20 +163,22 @@ impl TimelineActor { thread::Builder::new() .name("PullTimelineData".to_owned()) - .spawn(move || loop { - if !*is_recording.lock().unwrap() { - break; - } + .spawn(move || { + loop { + if !*is_recording.lock().unwrap() { + break; + } - let mut markers = vec![]; - while let Ok(Some(marker)) = receiver.try_recv() { - markers.push(emitter.marker(marker)); - } - if emitter.send(markers).is_err() { - break; - } + let mut markers = vec![]; + while let Ok(Some(marker)) = receiver.try_recv() { + markers.push(emitter.marker(marker)); + } + if emitter.send(markers).is_err() { + break; + } - thread::sleep(Duration::from_millis(DEFAULT_TIMELINE_DATA_PULL_TIMEOUT)); + thread::sleep(Duration::from_millis(DEFAULT_TIMELINE_DATA_PULL_TIMEOUT)); + } }) .expect("Thread spawning failed"); } |