Upgrade to ntex v3.0 (#33)

Author: fafhrd91

examples/custom/Cargo.toml

@@ -2,19 +2,19 @@
 name = "custom"
 version = "1.0.0"
 edition = "2024"
-rust-version = "1.85"
+rust-version = "1.88"
 
 [[bin]]
 name = "client"
 path = "src/client.rs"
 
 [dependencies]
-ntex = "3.0.0-pre.2"
-ntex-h2 = "3.0.0"
-ntex-grpc = "1.0.0"
+ntex = "3.0"
+ntex-h2 = "3.6"
+ntex-grpc = "1.0"
 
 env_logger = "0.11"
 uuid = { version = "1", features = ["v4"] }
 
 [dev-dependencies]
-ntex = { version = "3.0.0-pre.2", features = ["openssl", "tokio"] }
+ntex = { version = "3.0", features = ["openssl", "tokio"] }

examples/helloworld/Cargo.toml

@@ -2,7 +2,7 @@
 name = "helloworld"
 version = "1.0.0"
 edition = "2024"
-rust-version = "1.85"
+rust-version = "1.88"
 
 [[bin]]
 name = "client"
@@ -13,7 +13,7 @@ name = "server"
 path = "src/server.rs"
 
 [dependencies]
-ntex = { version = "3.0.0-pre.9", features = ["tokio"] }
+ntex = { version = "3.0", features = ["tokio"] }
 ntex-grpc = "1"
 ntex-h2 = "3"
 
@@ -23,4 +23,4 @@ env_logger = "0.11"
 num_cpus = "1"
 
 [dev-dependencies]
-ntex = { version = "3.0.0-pre.9", features = ["openssl", "tokio"] }
+ntex = { version = "3.0", features = ["openssl", "tokio"] }

examples/helloworld/src/client.rs

@@ -41,7 +41,7 @@ fn main() {
 
         thread::spawn(move || {
             println!("Starting thread: {t}");
-            let sys = System::new("client");
+            let sys = System::new("client", ntex::rt::DefaultRuntime);
 
             sys.block_on(async move {
                 let h2client = h2::ClientBuilder::with_default(addr)

examples/helloworld/src/server.rs

@@ -66,7 +66,7 @@ async fn main() -> std::io::Result<()> {
     let threads = parse_usize_default(matches.value_of("threads"), num_cpus::get());
 
     // bind to socket
-    Server::build()
+    Server::builder()
         .bind("helloworld", format!("0.0.0.0:{port}"), async move |_| {
             // create service
             server::GrpcServer::new(GreeterServer)

ntex-grpc-codegen/Cargo.toml

@@ -10,7 +10,7 @@ readme = "README.md"
 keywords = ["grpc"]
 categories = ["asynchronous", "network-programming"]
 edition = "2024"
-rust-version = "1.85"
+rust-version = "1.88"
 
 [[bin]]
 name = "ntex-grpc"

ntex-grpc-derive/Cargo.toml

@@ -7,7 +7,7 @@ repository = "https://github.com/ntex-rs/ntex-grpc"
 readme = "README.md"
 description = "A Protocol Buffers implementation for the Rust Language."
 edition = "2024"
-rust-version = "1.85"
+rust-version = "1.88"
 
 [lib]
 proc-macro = true

ntex-grpc/CHANGES.md

@@ -1,5 +1,9 @@
 # Changes
 
+## [1.3.0] - 2026-02-02
+
+* Upgrade to ntex v3.0
+
 ## [1.2.0] - 2025-12-22
 
 * Add "CONTENT-TYPE" header to server response

ntex-grpc/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "ntex-grpc"
-version = "1.2.0"
+version = "1.3.0"
 license = "MIT OR Apache-2.0"
 authors = ["Nikolay Kim <fafhrd91@gmail.com>"]
 description = "GRPC Client/Server framework"
@@ -10,14 +10,14 @@ readme = "README.md"
 keywords = ["grpc"]
 categories = ["asynchronous", "network-programming"]
 edition = "2024"
-rust-version = "1.85"
+rust-version = "1.88"
 
 [lib]
 name = "ntex_grpc"
 path = "src/lib.rs"
 
 [dependencies]
-ntex-h2 = "3.2"
+ntex-h2 = "3.6"
 ntex-http = "1"
 ntex-io = "3"
 ntex-util = "3"
@@ -33,4 +33,4 @@ pin-project-lite = "0.2"
 [dev-dependencies]
 openssl = "0.10"
 env_logger = "0.11"
-ntex = { version = "3.0.0-pre.9", features = ["openssl", "neon"] }
+ntex = { version = "3.0", features = ["openssl", "neon"] }

ntex-grpc/src/server/service.rs

@@ -120,13 +120,13 @@ where
 
 struct ControlService;
 
-impl Service<h2::ControlMessage<h2::StreamError>> for ControlService {
-    type Response = h2::ControlResult;
+impl Service<h2::Control<h2::StreamError>> for ControlService {
+    type Response = h2::ControlAck;
     type Error = ();
 
     async fn call(
         &self,
-        msg: h2::ControlMessage<h2::StreamError>,
+        msg: h2::Control<h2::StreamError>,
         _: ServiceCtx<'_, Self>,
     ) -> Result<Self::Response, Self::Error> {
         log::trace!("Control message: {msg:?}");

ntex-grpc/src/types.rs

@@ -85,7 +85,11 @@ pub trait NativeType: PartialEq + Default + Sized + fmt::Debug {
             DefaultValue::Value(d) => self == d,
         };
 
-        if default { 0 } else { self.encoded_len(tag) }
+        if default {
+            0
+        } else {
+            self.encoded_len(tag)
+        }
     }
 
     #[inline]
@@ -652,6 +656,7 @@ mod tests {
             Ok(msg)
         }
 
+        #[allow(clippy::identity_op)]
         #[inline]
         fn encoded_len(&self) -> usize {
             0 + NativeType::serialized_len(&self.f, 1, DefaultValue::Default)
@@ -661,6 +666,7 @@ mod tests {
         }
     }
 
+    #[allow(clippy::field_reassign_with_default)]
     #[test]
     fn test_hashmap_default_values() {
         let mut msg = TestMessage::default();