reduced warnings

Author: EnvOut

src/uactor/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "uactor"
-version = "0.13.1"
+version = "0.13.2"
 edition = "2021"
 repository = "https://github.com/EnvOut/uactor"
 license = "MIT"

src/uactor/src/actor/abstract_actor.rs

@@ -1,17 +1,13 @@
-use crate::actor::context::{ActorContext, ContextResult};
+use crate::actor::context::ActorContext;
 use crate::actor::message::Message;
 use std::future::Future;
-use std::pin::Pin;
 use std::sync::Arc;
-use std::sync::mpsc::Sender;
 use crate::actor::select::{ActorSelect, SelectError, SelectResult};
-use crate::data::datasource::{DataSource, DataSourceErrors};
 
 pub trait State: std::any::Any + Send + 'static {}
 impl<T: std::any::Any + Send + 'static> State for T {}
 
 use crate::dependency_injection::Inject;
-use crate::system::System;
 
 #[allow(unused_variables)]
 pub trait Actor: Sized + Unpin + 'static {
@@ -65,7 +61,7 @@ pub trait Actor: Sized + Unpin + 'static {
     }
 
     #[inline]
-    fn on_die(mut self, ctx: &mut Self::Context, state: &Self::State) -> impl Future<Output = ()> + Send {
+    fn on_die(self, ctx: &mut Self::Context, state: &Self::State) -> impl Future<Output = ()> + Send {
         async {}
     }
 }
@@ -106,9 +102,9 @@ pub trait MessageSender<M>
 where
     M: Message,
 {
-    async fn send(&self, msg: M) -> crate::data::data_publisher::DataPublisherResult;
-    async fn ask<A>(
+    fn send(&self, msg: M) -> impl std::future::Future<Output = crate::data::data_publisher::DataPublisherResult> + Send;
+    fn ask<A>(
         &self,
         f: impl FnOnce(tokio::sync::oneshot::Sender<A>) -> M,
-    ) -> Result<A, crate::data::data_publisher::DataPublisherErrors>;
+    ) -> impl std::future::Future<Output = Result<A, crate::data::data_publisher::DataPublisherErrors>> + Send;
 }

src/uactor/src/actor/select.rs

@@ -1,4 +1,4 @@
-use crate::actor::abstract_actor::{Actor, Handler};
+use crate::actor::abstract_actor::Actor;
 use crate::actor::message::Message;
 use crate::data::datasource::{DataSource, DataSourceErrors, DataSourceResult};
 use std::future::pending;

src/uactor/src/data/data_publisher.rs

@@ -26,7 +26,6 @@ mod async_sender {
 
     impl<T: ?Sized> TryClone for &T {
         #[inline(always)]
-        #[rustc_diagnostic_item = "noop_method_clone"]
         fn try_clone(&self) -> Result<Self, TryCloneError> {
             Ok(*self)
         }

src/uactor/src/data/datasource.rs

@@ -1,11 +1,9 @@
 use std::net::{Ipv4Addr, SocketAddrV4};
-use std::pin::Pin;
-use std::task::{Context, Poll};
 use tokio::net::{TcpListener, TcpStream};
 use tokio::sync::{broadcast, mpsc, oneshot, watch};
 use tokio::time::Interval;
 
-use crate::actor::message::{IntervalMessage, Message};
+use crate::actor::message::IntervalMessage;
 
 pub type DataSourceResult<T> = Result<T, DataSourceErrors>;
 

src/uactor/src/data/datasource_decorator/mod.rs

@@ -1,7 +1,6 @@
 use crate::actor::message::Message;
 use crate::data::datasource::DataSource;
 use crate::data::datasource_decorator::timeout_impl::TimeoutDecorator;
-use futures::FutureExt;
 use std::time::Duration;
 
 mod timeout_impl;

src/uactor/src/data/datasource_decorator/timeout_impl.rs

@@ -1,10 +1,8 @@
 use crate::actor::message::Message;
 use crate::data::datasource::{DataSource, DataSourceErrors, DataSourceResult};
-use futures::{FutureExt, TryFutureExt};
+use futures::FutureExt;
 use std::future::Future;
 use std::time::Duration;
-use tokio_stream::StreamExt;
-
 #[derive(derive_more::Constructor)]
 pub struct TimeoutDecorator<M, D>
 where

src/uactor/src/dependency_injection/mod.rs

@@ -41,7 +41,6 @@ pub trait Inject {
 }
 
 pub mod inject_impls {
-    use crate::actor::abstract_actor::Actor;
     use crate::dependency_injection::{Inject, InjectError};
     use crate::system::System;
 

src/uactor/src/system/mod.rs

@@ -1,20 +1,15 @@
-use crate::actor;
 use crate::actor::abstract_actor::{Actor, Handler};
 use crate::actor::context::actor_registry::{ActorRegistry, ActorRegistryErrors};
 use crate::actor::context::extensions::{ExtensionErrors, Extensions, Service};
 use crate::actor::context::ActorContext;
 use crate::actor::message::Message;
-use crate::actor::select::{ActorSelect, SelectResult};
+use crate::actor::select::ActorSelect;
 use crate::aliases::ActorName;
-use crate::data::data_publisher::{DataPublisher, TryClone, TryCloneError};
+use crate::data::data_publisher::{DataPublisher, TryCloneError};
 use crate::dependency_injection::{Inject, InjectError};
 use crate::system::builder::SystemBuilder;
-use std::any::Any;
-use std::collections::HashMap;
-use std::pin::pin;
 use std::sync::Arc;
 use tokio::sync::mpsc::UnboundedSender;
-use tokio::sync::{oneshot, RwLock};
 use tokio::task::JoinHandle;
 use crate::system::global::GlobalSystem;
 
@@ -36,7 +31,6 @@ pub enum ActorRunningError {
 pub struct System {
     name: Arc<str>,
     extensions: Extensions,
-    initialized_actors: HashMap<Arc<str>, oneshot::Sender<Box<dyn Any + Send>>>,
     actor_registry: ActorRegistry,
 }
 
@@ -55,7 +49,7 @@ impl System {
         M: Message + Send + 'static,
         R: From<(ActorName, UnboundedSender<M>, A::State)>,
     {
-        let (mut tx, rx) = tokio::sync::mpsc::unbounded_channel::<M>();
+        let (tx, rx) = tokio::sync::mpsc::unbounded_channel::<M>();
 
         let actor_name: Arc<str> = actor_name.to_owned().into();
         let state = A::State::default();
@@ -285,7 +279,6 @@ pub mod builder {
                 Arc::from(self.name.as_str()),
                 self.extensions,
                 Default::default(),
-                Default::default(),
             )
         }
     }