Removed the requirement of implementing Clone on CallMsg and CastMsg

Author: ElFantasma

concurrency/src/tasks/gen_server.rs

@@ -105,8 +105,8 @@ pub trait GenServer
 where
     Self: Send + Sized,
 {
-    type CallMsg: Clone + Send + Sized + Sync;
-    type CastMsg: Clone + Send + Sized + Sync;
+    type CallMsg: Send + Sized + Sync;
+    type CastMsg: Send + Sized + Sync;
     type OutMsg: Send + Sized;
     type State: Clone + Send;
     type Error: Debug + Send;

concurrency/src/tasks/time.rs

@@ -27,7 +27,7 @@ where
             Box::pin(cloned_token.cancelled()),
             Box::pin(async {
                 rt::sleep(period).await;
-                let _ = handle.cast(message.clone()).await;
+                let _ = handle.cast(message).await;
             }),
         )
         .await;
@@ -46,6 +46,7 @@ pub fn send_interval<T>(
 ) -> TimerHandle
 where
     T: GenServer + 'static,
+    T::CastMsg: Clone,
 {
     let cancellation_token = CancellationToken::new();
     let cloned_token = cancellation_token.clone();

concurrency/src/threads/gen_server.rs

@@ -83,8 +83,8 @@ pub trait GenServer
 where
     Self: Send + Sized,
 {
-    type CallMsg: Clone + Send + Sized;
-    type CastMsg: Clone + Send + Sized;
+    type CallMsg: Send + Sized;
+    type CastMsg: Send + Sized;
     type OutMsg: Send + Sized;
     type State: Clone + Send;
     type Error: Debug;

concurrency/src/threads/time.rs

@@ -41,6 +41,7 @@ pub fn send_interval<T>(
 ) -> TimerHandle
 where
     T: GenServer + 'static,
+    T::CastMsg: Clone,
 {
     let cancellation_token = CancellationToken::new();
     let mut cloned_token = cancellation_token.clone();