Make sure to propagate the exit reason returned from GenServer::init.

Author: dtzxporter

CHANGELOG.md

@@ -6,6 +6,11 @@
 
 ### Fixed
 
+# 0.1.37
+
+### Fixed
+- Properly propagate exit reason returned from `GenServer::init`.
+
 # 0.1.36
 
 ### Changed

Cargo.toml

@@ -33,8 +33,8 @@ tracing = { version = "0.1", default-features = false, features = ["std"] }
 tracing-subscriber = "0.3"
 dashmap = "6.0.1"
 
-hydra-macros = { version = "0.1.36", path = "./hydra-macros" }
-hydra = { version = "0.1.36", path = "./hydra", default-features = false }
+hydra-macros = { version = "0.1.37", path = "./hydra-macros" }
+hydra = { version = "0.1.37", path = "./hydra", default-features = false }
 
 [profile.release]
 lto = "fat"

hydra-macros/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "hydra-macros"
-version = "0.1.36"
+version = "0.1.37"
 edition = "2021"
 license.workspace = true
 repository.workspace = true

hydra-websockets/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "hydra-websockets"
-version = "0.1.36"
+version = "0.1.37"
 edition = "2021"
 readme = "./README.md"
 license.workspace = true

hydra/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "hydra"
-version = "0.1.36"
+version = "0.1.37"
 edition = "2021"
 readme.workspace = true
 license.workspace = true

hydra/src/gen_server.rs

@@ -386,14 +386,14 @@ async fn start_gen_server<T: GenServer>(
                 tx.send(Ok(())).expect("Failed to notify parent process!");
             }
             Ok(Err(reason)) => {
-                tx.send(Err(reason))
+                tx.send(Err(reason.clone()))
                     .expect("Failed to notify parent process!");
-                return;
+                return Process::exit(Process::current(), reason);
             }
             Err(_) => {
                 tx.send(Err(ExitReason::from("timeout")))
                     .expect("Failed to notify parent process!");
-                return;
+                return Process::exit(Process::current(), ExitReason::from("timeout"));
             }
         }