removed spans for handle

Author: EnvOut

Cargo.lock

@@ -8,7 +8,7 @@ members = [
 ]
 
 [workspace.dependencies]
-tokio = { version = "1.35.0", features = ["sync", "time", "rt", "macros"] }
+tokio = { version = "1.35.0", features = ["net", "sync", "time", "rt", "macros"] }
 futures = "0.3"
 
 # errors

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "uactor"
-version = "0.10.1"
+version = "0.10.3"
 edition = "2021"
 repository = "https://github.com/EnvOut/uactor"
 license = "MIT"
@@ -23,7 +23,7 @@ rand = "0.8"
 tracing-subscriber = { version = "0.3" }
 anyhow = "1"
 time = "0.3"
-tokio = { version = "1.35.1", features = ["full"] }
+tokio.workspace = true
 
 [[example]]
 name = "base_sample"

src/uactor/Cargo.toml

@@ -113,6 +113,7 @@ pub type EmptyState = ();
 /// use uactor::actor::{Actor, HandleResult};
 /// use uactor::context::Context;
 /// use uactor::system::System;
+/// use uactor::actor::EmptyState;
 /// let mut system = System::global().build();
 /// pub struct Actor1;
 /// impl Actor for Actor1 { type Context = Context; type Inject = (); }
@@ -122,7 +123,7 @@ pub type EmptyState = ();
 /// pub struct Ping;
 /// impl Message for Ping { fn static_name() -> &'static str { "Ping" } }
 /// impl uactor::actor::Handler<Ping> for Actor1 { async fn handle(&mut self, inject: &mut Self::Inject, msg: Ping, ctx: &mut Self::Context) -> HandleResult { todo!() }  }
-/// uactor::generate_actor_ref!(Actor1, { });
+/// uactor::generate_actor_ref!(Actor1, { }, EmptyState);
 /// ```
 /// let (mut actor1_ref, handle) = uactor::spawn_with_ref!(system, actor1: Actor1);
 #[macro_export]

src/uactor/src/actor.rs

@@ -1,10 +1,10 @@
 use std::net::{Ipv4Addr, SocketAddrV4};
 use tokio::net::{TcpListener, TcpStream};
-use tokio::net::unix::SocketAddr;
-use crate::message::IntervalMessage;
 use tokio::sync::{broadcast, mpsc, oneshot, watch};
 use tokio::time::Interval;
 
+use crate::message::IntervalMessage;
+
 pub type DataSourceResult<T> = Result<T, DataSourceErrors>;
 
 #[derive(thiserror::Error, Debug)]

src/uactor/src/datasource.rs

@@ -64,8 +64,6 @@ mod select_from_tuple {
             // let message_name = <S1 as DataSource>::Item::static_name();
             let message_name: &'static str = type_name::<<S1 as DataSource>::Item>();
             if let Ok(msg) = self.next().await {
-                let mut span = tracing::span!(tracing::Level::INFO, "Actor::handle", actor.name = ctx.get_name(), actor.message = message_name);
-                let _enter = span.enter();
                 let _ = actor.handle(inject, msg, ctx).await?;
             } else {
                 tracing::error!("Channel closed");