Merge pull request #31 from cherish-ltt/v1.1.x

V1.1.8

Author: cherish-ltt

Cargo.lock

@@ -1,8 +1,8 @@
 [package]
 name = "lynn_tcp"
-version = "1.1.7"
-edition = "2021"
-rust-version = "1.83"
+version = "1.1.8"
+edition = "2024"
+rust-version = "1.85"
 authors = ["lynn_tcp Contributors"]
 license = "MIT"
 readme = "README.md"

Cargo.toml

@@ -36,21 +36,21 @@ Use `cargo add lynn_tcp` or:
 
 ```rust
 [dependencies]
-lynn_tcp = "1.1.7"
+lynn_tcp = "1.1.8"
 ```
 
 **server feature**
 
 ```rust
 [dependencies]
-lynn_tcp = { version = "1.1.7" , features = "server" }
+lynn_tcp = { version = "1.1.8" , features = "server" }
 ```
 
 **client feature**
 
 ```rust
 [dependencies]
-lynn_tcp = { version = "1.1.7" , features = "client" }
+lynn_tcp = { version = "1.1.8" , features = "client" }
 ```
 
 #### Server
@@ -60,6 +60,8 @@ use lynn_tcp::{lynn_server::*, lynn_tcp_dependents::*};
 
 #[tokio::main]
 async fn main() -> Result<(), Box<dyn std::error::Error>> {
+    // Initialize tracing or use app.logserver()
+    tracing_subscriber::fmt::init();
     let _ = LynnServer::new()
         .await
         .add_router(1, my_service)
@@ -92,6 +94,8 @@ use lynn_tcp::{lynn_server::*, lynn_tcp_dependents::*};
 
 #[tokio::main]
 async fn main() -> Result<(), Box<dyn std::error::Error>> {
+    // Initialize tracing or use app.logserver()
+    tracing_subscriber::fmt::init();
     let _ = LynnServer::new_with_config(
         LynnServerConfigBuilder::new()
             .with_addr("0.0.0.0:9177")
@@ -138,7 +142,9 @@ use lynn_tcp::{
 
 #[tokio::main]
 async fn main() -> Result<(), Box<dyn std::error::Error>> {
-    let client = LynnClient::new_with_ipv4("127.0.0.1:9177")
+    // Initialize tracing or use app.logserver()
+    tracing_subscriber::fmt::init();
+    let client = LynnClient::new_with_addr("127.0.0.1:9177")
             .await
             .start()
             .await;

README.md

@@ -47,6 +47,8 @@ pub mod lynn_config_api {
 ///
 /// #[tokio::main]
 /// async fn main() -> Result<(), Box<dyn std::error::Error>> {
+///     // Initialize tracing or use app.logserver()
+///     tracing_subscriber::fmt::init();
 ///     let _ = LynnServer::new()
 ///         .await
 ///         .add_router(1, my_service)
@@ -78,6 +80,8 @@ pub mod lynn_config_api {
 ///
 /// #[tokio::main]
 /// async fn main() -> Result<(), Box<dyn std::error::Error>> {
+///     // Initialize tracing or use app.logserver()
+///     tracing_subscriber::fmt::init();
 ///     let _ = LynnServer::new_with_config(
 ///         LynnServerConfigBuilder::new()
 ///             .with_addr("0.0.0.0:9177")
@@ -149,7 +153,6 @@ impl<'a> LynnServer<'a> {
             lynn_config,
             lynn_thread_pool: thread_pool,
         };
-        app.log_server().await;
         app
     }
 
@@ -176,7 +179,6 @@ impl<'a> LynnServer<'a> {
             lynn_config,
             lynn_thread_pool: thread_pool,
         };
-        app.log_server().await;
         app
     }
 
@@ -203,7 +205,6 @@ impl<'a> LynnServer<'a> {
             lynn_config,
             lynn_thread_pool: thread_pool,
         };
-        app.log_server().await;
         app
     }
 
@@ -226,7 +227,6 @@ impl<'a> LynnServer<'a> {
             lynn_config,
             lynn_thread_pool: thread_pool,
         };
-        app.log_server().await;
         app
     }
 
@@ -390,7 +390,9 @@ impl<'a> LynnServer<'a> {
     }
 
     /// Logs server information.
-    async fn log_server(&self) {
+    /// since v1.1.8 Users need to manually activate it
+    #[cfg(feature = "server")]
+    pub fn log_server(&self) {
         let subscriber = fmt::Subscriber::builder()
             .with_max_level(Level::INFO)
             .finish();

src/app/mod.rs

@@ -31,7 +31,9 @@ pub mod client_config {
 ///
 /// #[tokio::main]
 /// async fn main() -> Result<(), Box<dyn std::error::Error>> {
-///     let client = LynnClient::new_with_ipv4("127.0.0.1:9177")
+///     // Initialize tracing or use app.logserver()
+///     tracing_subscriber::fmt::init();
+///     let client = LynnClient::new_with_addr("127.0.0.1:9177")
 ///             .await
 ///             .start()
 ///             .await;
@@ -69,7 +71,6 @@ impl<'a> LynnClient<'a> {
             tx_write: None,
             rx_read: None,
         };
-        client.log_server().await;
         client
     }
 
@@ -92,7 +93,6 @@ impl<'a> LynnClient<'a> {
             tx_write: None,
             rx_read: None,
         };
-        client.log_server().await;
         client
     }
 
@@ -117,7 +117,6 @@ impl<'a> LynnClient<'a> {
             tx_write: None,
             rx_read: None,
         };
-        client.log_server().await;
         client
     }
 
@@ -188,7 +187,9 @@ impl<'a> LynnClient<'a> {
     }
 
     /// Logs the server information.
-    pub(crate) async fn log_server(&self) {
+    /// since v1.1.8 Users need to manually activate it
+    #[cfg(feature = "client")]
+    pub fn log_server(&self) {
         let subscriber = fmt::Subscriber::builder()
             .with_max_level(Level::INFO)
             .finish();

src/client/mod.rs

@@ -2,6 +2,12 @@
 
 ### v1.1.x - release
 
+#### v1.1.8 - release
+
+1.perf
+
+- logserver(Server and Clinet) Now users need to manually initialize the logs
+
 #### v1.1.7 - release
 
 1.feat