Update ractor to 0.15.7 (#380)

* Update ractor to 0.15.7

Semver checks are clean indicating no need for a major release with these changes

```
$ cargo semver-checks -p ractor
    Building ractor v0.15.7 (current)
       Built [   8.412s] (current)
     Parsing ractor v0.15.7 (current)
      Parsed [   0.012s] (current)
    Building ractor v0.15.6 (baseline)
       Built [   7.274s] (baseline)
     Parsing ractor v0.15.6 (baseline)
      Parsed [   0.012s] (baseline)
    Checking ractor v0.15.6 -> v0.15.7 (minor change)
     Checked [   0.035s] 140 checks: 140 pass, 37 skip
     Summary no semver update required
    Finished [  20.651s] ractor
```

* DerivedActorRef::send_after bug fix + test coverage

* Formatting

---------

Co-authored-by: Utku Demir <utku@rilla.network>

Author: slawlor

ractor/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "ractor"
-version = "0.15.6"
+version = "0.15.7"
 authors = ["Sean Lawlor", "Evan Au", "Dillon George"]
 description = "A actor framework for Rust"
 documentation = "https://docs.rs/ractor"

ractor/src/actor/tests.rs

@@ -1345,6 +1345,18 @@ async fn derived_actor_ref() {
         .send_message(u16_message)
         .expect("Failed to send message to actor");
 
+    // timer
+    actor
+        .get_derived()
+        .send_after(Duration::from_millis(10), move || u16_message)
+        .await
+        .expect("Failed to await the join handle")
+        .expect("Failed to send message to actor");
+
+    sum += u16_message as u32;
+
+    // Make sure delayed send is received
+    crate::concurrency::sleep(Duration::from_millis(50)).await;
     actor
         .drain_and_wait(None)
         .await

ractor/src/thread_local.rs

@@ -415,6 +415,7 @@ impl ThreadLocalActorSpawner {
     }
 
     #[cfg(all(feature = "async-std", not(target_arch = "wasm32")))]
+    /// Create a new [ThreadLocalActorSpawner] on the current thread.
     pub fn new() -> Self {
         let (send, mut recv) = crate::concurrency::mpsc_unbounded();
 

ractor/src/time.rs

@@ -232,7 +232,22 @@ where
     where
         F: Fn() -> TMessage + Send + 'static,
     {
-        send_interval::<TMessage, F>(period, self.get_cell(), msg)
+        // IMPORTANT: See notes on `send_interval` above for important implementation
+        // notes
+        let self_clone = self.clone();
+        crate::concurrency::spawn(async move {
+            let mut timer = crate::concurrency::interval(period);
+            // timer tick's immediately the first time
+            timer.tick().await;
+            while ACTIVE_STATES.contains(&self_clone.get_status()) {
+                timer.tick().await;
+                // if we receive an error trying to send, the channel is closed and we should stop trying
+                // actor died
+                if self_clone.send_message(msg()).is_err() {
+                    break;
+                }
+            }
+        })
     }
 
     /// Alias of [send_after]
@@ -244,7 +259,12 @@ where
     where
         F: FnOnce() -> TMessage + Send + 'static,
     {
-        send_after::<TMessage, F>(period, self.get_cell(), msg)
+        let self_clone = self.clone();
+        crate::concurrency::spawn(async move {
+            crate::concurrency::sleep(period).await;
+            let msg = msg();
+            self_clone.send_message(msg)
+        })
     }
 
     /// Alias of [exit_after]

ractor_cluster/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "ractor_cluster"
-version = "0.15.6"
+version = "0.15.7"
 authors = ["Sean Lawlor <slawlor>"]
 description = "Distributed cluster environment of Ractor actors"
 documentation = "https://docs.rs/ractor"

ractor_cluster_derive/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "ractor_cluster_derive"
-version = "0.15.6"
+version = "0.15.7"
 authors = ["Sean Lawlor <slawlor>"]
 description = "Derives for ractor_cluster"
 license = "MIT"