Skip to content

Commit 9f2b978

Browse files
committed
fmt
1 parent d35fd0a commit 9f2b978

2 files changed

Lines changed: 5 additions & 8 deletions

File tree

crates/core/src/host/module_host.rs

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1718,8 +1718,7 @@ impl ModuleHost {
17181718
let metrics = InstanceManagerMetrics::new(module.host_type(), database_identity);
17191719
let main_state = WasmtimeModuleState::new(module.clone(), init_inst, metrics.clone());
17201720

1721-
let executor =
1722-
core.spawn_executor(main_state, thread_name);
1721+
let executor = core.spawn_executor(main_state, thread_name);
17231722
let procedure_instances = Arc::new(ModuleInstanceManager::new_bounded_with_metrics(
17241723
procedure_module,
17251724
None,

crates/core/src/util/jobs.rs

Lines changed: 4 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -220,11 +220,7 @@ pub struct AllocatedJobCore {
220220

221221
impl AllocatedJobCore {
222222
/// Spawn a [`SingleThreadedExecutor`] for this allocated core.
223-
pub fn spawn_executor<S: Send + 'static>(
224-
self,
225-
state: S,
226-
name: impl Into<String>,
227-
) -> SingleThreadedExecutor<S> {
223+
pub fn spawn_executor<S: Send + 'static>(self, state: S, name: impl Into<String>) -> SingleThreadedExecutor<S> {
228224
SingleThreadedExecutor::spawn_and_pin(Arc::new(self.guard), self.pinner, state, Some(name.into()))
229225
}
230226
}
@@ -357,7 +353,9 @@ impl<S: Send + 'static> SingleThreadedExecutor<S> {
357353
// dropped and cancelled.
358354
rt.block_on(local)
359355
};
360-
thread.spawn(worker).expect("failed to spawn SingleThreadedExecutor thread");
356+
thread
357+
.spawn(worker)
358+
.expect("failed to spawn SingleThreadedExecutor thread");
361359

362360
Self { inner }
363361
}

0 commit comments

Comments
 (0)