reorder methods

loco-rs · Oct 31, 2024 · 84b6b2a · 84b6b2a
1 parent 7ad937d
commit 84b6b2a
Showing 1 changed file with 16 additions and 16 deletions.
diff --git a/src/boot.rs b/src/boot.rs
@@ -110,22 +110,6 @@ pub async fn start<H: Hooks>(
     Ok(())
 }
 
-async fn shutdown_and_await_queue_worker(
-    app_context: &AppContext,
-    handle: JoinHandle<()>,
-) -> Result<(), Error> {
-    if let Some(queue) = &app_context.queue_provider {
-        queue.shutdown()?;
-    }
-
-    println!("press ctrl-c again to force quit");
-    select! {
-        _ = handle => {}
-        () = shutdown_signal() => {}
-    }
-    Ok(())
-}
-
 fn start_queue_worker(app_context: &AppContext) -> Result<JoinHandle<()>> {
     debug!("note: worker is run in-process (tokio spawn)");
 
@@ -146,6 +130,22 @@ fn start_queue_worker(app_context: &AppContext) -> Result<JoinHandle<()>> {
     Err(Error::QueueProviderMissing)
 }
 
+async fn shutdown_and_await_queue_worker(
+    app_context: &AppContext,
+    handle: JoinHandle<()>,
+) -> Result<(), Error> {
+    if let Some(queue) = &app_context.queue_provider {
+        queue.shutdown()?;
+    }
+
+    println!("press ctrl-c again to force quit");
+    select! {
+        _ = handle => {}
+        () = shutdown_signal() => {}
+    }
+    Ok(())
+}
+
 /// Run task
 ///
 /// # Errors