Actually return the GenServer::init result.

Author: dtzxporter

CHANGELOG.md

@@ -6,6 +6,11 @@
 
 ### Fixed
 
+# 0.1.38
+
+### Fixed
+- Return if process exited from `GenServer::init`.
+
 # 0.1.37
 
 ### Fixed

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.37", path = "./hydra-macros" }
-hydra = { version = "0.1.37", path = "./hydra", default-features = false }
+hydra-macros = { version = "0.1.38", path = "./hydra-macros" }
+hydra = { version = "0.1.38", path = "./hydra", default-features = false }
 
 [profile.release]
 lto = "fat"

hydra-macros/Cargo.toml

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

hydra-websockets/Cargo.toml

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

hydra/Cargo.toml

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

hydra/src/gen_server.rs

@@ -130,7 +130,6 @@ pub trait GenServer: Sized + Send + 'static {
     /// Starts a [GenServer] process linked to the current process.
     fn start_link(
         self,
-
         options: GenServerOptions,
     ) -> impl Future<Output = Result<Pid, ExitReason>> + Send {
         async { start_gen_server(self, options, true).await }
@@ -460,6 +459,6 @@ async fn start_gen_server<T: GenServer>(
     };
 
     rx.await
+        .map_err(|_| ExitReason::from("unknown"))?
         .map(|_| pid)
-        .map_err(|_| ExitReason::from("unknown"))
 }