allow specifying schedule

Author: databasedav

CHANGELOG.md

@@ -4,6 +4,12 @@ the format is based on [Keep a Changelog](https://keepachangelog.com/en/1.1.0/)
 
 ## unreleased
 
+# 0.3.2 (2025-11-28)
+
+### added
+
+- allow specifying custom schedule for the `JonmoPlugin`
+
 # 0.4.1 (2025-11-27)
 
 ### fixed

Cargo.lock

@@ -1,6 +1,6 @@
 [package]
 name = "jonmo"
-version = "0.4.1"
+version = "0.4.2"
 edition = "2024"
 categories = ["asynchronous", "gui", "game-development"]
 description = "ergonomic Bevy-native reactivity powered by FRP signals"

Cargo.toml

@@ -169,7 +169,7 @@ pub(crate) fn examples_plugin(app: &mut App) {
             }),
             ..default()
         }),
-        JonmoPlugin,
+        JonmoPlugin::default(),
         #[cfg(feature = "debug")]
         DebugUiPlugin,
     ))

examples/utils.rs

@@ -712,7 +712,7 @@ mod tests {
     fn create_test_app() -> App {
         cleanup();
         let mut app = App::new();
-        app.add_plugins((MinimalPlugins, JonmoPlugin));
+        app.add_plugins((MinimalPlugins, JonmoPlugin::default()));
         app
     }
 

src/builder.rs

@@ -9,7 +9,10 @@
 extern crate alloc;
 
 use bevy_app::prelude::*;
-use bevy_ecs::prelude::*;
+use bevy_ecs::{
+    prelude::*,
+    schedule::{InternedScheduleLabel, ScheduleLabel},
+};
 
 #[cfg(feature = "builder")]
 pub mod builder;
@@ -21,8 +24,67 @@ pub mod signal_vec;
 pub mod utils;
 
 /// Includes the systems required for [jonmo](crate) to function.
-#[derive(Default)]
-pub struct JonmoPlugin;
+///
+/// # Example
+///
+/// ```rust
+/// use bevy_app::prelude::*;
+/// use bevy_ecs::prelude::*;
+/// use jonmo::{SignalProcessing, prelude::*};
+///
+/// let mut app = App::new();
+/// // Use default configuration (runs in Last schedule)
+/// app.add_plugins(JonmoPlugin::default());
+///
+/// let mut app = App::new();
+/// // Or customize the schedule
+/// app.add_plugins(JonmoPlugin::new().in_schedule(PostUpdate));
+///
+/// // Add ordering constraints using configure_sets
+/// # #[derive(SystemSet, Debug, Clone, PartialEq, Eq, Hash)]
+/// # struct SystemSet1;
+///
+/// # #[derive(SystemSet, Debug, Clone, PartialEq, Eq, Hash)]
+/// # struct SystemSet2;
+///
+/// app.configure_sets(
+///     PostUpdate,
+///     SignalProcessing.before(SystemSet1).before(SystemSet2),
+/// );
+/// ```
+pub struct JonmoPlugin {
+    schedule: InternedScheduleLabel,
+}
+
+impl Default for JonmoPlugin {
+    fn default() -> Self {
+        Self {
+            schedule: Last.intern(),
+        }
+    }
+}
+
+impl JonmoPlugin {
+    /// Create a new `JonmoPlugin` with signal processing running in the `Last` schedule.
+    pub fn new() -> Self {
+        Self::default()
+    }
+
+    /// Specify which schedule the signal processing systems should run in.
+    ///
+    /// # Example
+    ///
+    /// ```rust
+    /// use bevy_app::prelude::*;
+    /// use jonmo::prelude::*;
+    ///
+    /// JonmoPlugin::new().in_schedule(Update);
+    /// ```
+    pub fn in_schedule(mut self, schedule: impl ScheduleLabel) -> Self {
+        self.schedule = schedule.intern();
+        self
+    }
+}
 
 /// [`SystemSet`] that can be used to schedule systems around signal processing.
 #[derive(SystemSet, Debug, Clone, PartialEq, Eq, Hash)]
@@ -31,7 +93,7 @@ pub struct SignalProcessing;
 impl Plugin for JonmoPlugin {
     fn build(&self, app: &mut App) {
         app.add_systems(
-            Last,
+            self.schedule,
             (
                 (
                     signal_vec::trigger_replays::<signal_vec::VecReplayTrigger>,

src/lib.rs

@@ -2270,7 +2270,7 @@ mod tests {
 
     fn create_test_app() -> App {
         let mut app = App::new();
-        app.add_plugins((MinimalPlugins, JonmoPlugin));
+        app.add_plugins((MinimalPlugins, JonmoPlugin::default()));
         app.register_type::<TestData>();
         app
     }
@@ -3121,7 +3121,7 @@ mod tests {
     #[test]
     fn test_throttle() {
         let mut app = App::new();
-        app.add_plugins((MinimalPlugins.build().disable::<TimePlugin>(), JonmoPlugin));
+        app.add_plugins((MinimalPlugins.build().disable::<TimePlugin>(), JonmoPlugin::default()));
         app.init_resource::<Time>(); // manually managing time for the test
         app.init_resource::<SignalOutput<i32>>();
 

src/signal.rs

@@ -1453,7 +1453,7 @@ pub(crate) mod tests {
     fn create_test_app() -> App {
         cleanup(true);
         let mut app = App::new();
-        app.add_plugins((MinimalPlugins, JonmoPlugin));
+        app.add_plugins((MinimalPlugins, JonmoPlugin::default()));
         app
     }
 

src/signal_map.rs

@@ -4063,7 +4063,7 @@ pub(crate) mod tests {
     fn create_test_app() -> App {
         cleanup(true);
         let mut app = App::new();
-        app.add_plugins((MinimalPlugins, JonmoPlugin));
+        app.add_plugins((MinimalPlugins, JonmoPlugin::default()));
         app
     }