Squashed and signed

Signed-off-by: Suneet Nangia <[email protected]>

examples/spin-timer/app-example/src/lib.rs

@@ -6,9 +6,12 @@ wit_bindgen::generate!({
 struct MySpinTimer;
 
 impl SpinTimer for MySpinTimer {
-    fn handle_timer_request() {
+    fn handle_timer_request() -> ContinueTimer {
         let text = spin_sdk::config::get("message").unwrap();
         println!("{text}");
+
+        // Return ContinueTimer::True if you want to continue the timer loop calling this component/function subsequently.
+        ContinueTimer::True
     }
 }
 

examples/spin-timer/spin-timer.wit

@@ -1,3 +1,10 @@
 default world spin-timer {
-  export handle-timer-request: func()
+  // Timer execution loop exit variant
+  variant continue-timer {      
+      true,
+      false
+  }
+
+  // Get the value of a key.
+  export handle-timer-request: func() -> continue-timer
 }

examples/spin-timer/src/main.rs

@@ -109,7 +109,15 @@ impl TriggerExecutor for TimerTrigger {
                         let duration = tokio::time::Duration::from_millis(*d * 1000 / speedup);
                         loop {
                             tokio::time::sleep(duration).await;
-                            self.handle_timer_event(c).await.unwrap();
+
+                            // Inverse the control of breaking out of loop, let the component decide this by returning ContinueTimer enum.
+                            let exit_condition = self.handle_timer_event(c).await.unwrap();
+
+                            // Exit the loop if the component asks for it.
+                            match exit_condition {
+                                ContinueTimer::True => continue,
+                                ContinueTimer::False => break,
+                            }
                         }
                     });
                 }
@@ -120,7 +128,7 @@ impl TriggerExecutor for TimerTrigger {
 }
 
 impl TimerTrigger {
-    async fn handle_timer_event(&self, component_id: &str) -> anyhow::Result<()> {
+    async fn handle_timer_event(&self, component_id: &str) -> anyhow::Result<ContinueTimer> {
         // Load the guest...
         let (instance, mut store) = self.engine.prepare_instance(component_id).await?;
         let EitherInstance::Component(instance) = instance else {