chore: address nightly warnings

actix/examples/weak_addr.rs

@@ -7,7 +7,7 @@
 
 use std::time::{Duration, Instant};
 
-use actix::{prelude::*, Actor, Context, WeakAddr};
+use actix::{prelude::*, WeakAddr};
 
 #[derive(Message, Debug)]
 #[rtype(result = "()")]

actix/examples/weak_recipient.rs

@@ -7,7 +7,7 @@
 
 use std::time::{Duration, Instant};
 
-use actix::{prelude::*, Actor, Context, WeakRecipient};
+use actix::{prelude::*, WeakRecipient};
 
 #[derive(Message, Debug)]
 #[rtype(result = "()")]

actix/src/address/channel.rs

@@ -896,7 +896,7 @@ fn encode_state(state: &State) -> usize {
 
 #[cfg(test)]
 mod tests {
-    use std::{thread, time};
+    use std::time;
 
     use super::*;
     use crate::{address::queue::PopResult, prelude::*};

actix/src/address/mod.rs

@@ -141,11 +141,11 @@ impl<A: Actor> Addr<A> {
     }
 
     /// Returns the [`Recipient`] for a specific message type.
-    pub fn recipient<M: 'static>(self) -> Recipient<M>
+    pub fn recipient<M>(self) -> Recipient<M>
     where
         A: Handler<M>,
         A::Context: ToEnvelope<A, M>,
-        M: Message + Send,
+        M: Message + Send + 'static,
         M::Result: Send,
     {
         self.into()
@@ -210,11 +210,11 @@ impl<A: Actor> WeakAddr<A> {
         }
     }
 
-    pub fn recipient<M: 'static>(self) -> WeakRecipient<M>
+    pub fn recipient<M>(self) -> WeakRecipient<M>
     where
         A: Handler<M>,
         A::Context: ToEnvelope<A, M>,
-        M: Message + Send,
+        M: Message + Send + 'static,
         M::Result: Send,
     {
         self.into()

actix/tests/test_address.rs

@@ -1,6 +1,5 @@
 use std::{
     collections::HashSet,
-    mem::drop,
     sync::{
         atomic::{AtomicUsize, Ordering},
         Arc,

actix/tests/test_context.rs

@@ -13,7 +13,6 @@ use std::{
 
 use actix::prelude::*;
 use actix_rt::time::{interval_at, sleep, Instant};
-use futures_core::stream::Stream;
 use futures_util::stream::once;
 use tokio::sync::mpsc::{unbounded_channel, UnboundedReceiver};