diff --git a/Cargo.toml b/Cargo.toml index 75dd0de6b..da3a7d3cd 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -3,7 +3,6 @@ name = "temporal-sdk-core" version = "0.1.0" authors = ["Spencer Judge ", "Vitaly Arbuzov "] edition = "2018" -license = "MIT" license-file = "LICENSE.txt" [lib] diff --git a/fsm/Cargo.toml b/fsm/Cargo.toml index 534af9f77..0431c4a7a 100644 --- a/fsm/Cargo.toml +++ b/fsm/Cargo.toml @@ -3,7 +3,6 @@ name = "rustfsm" version = "0.1.0" authors = ["Spencer Judge "] edition = "2018" -license = "MIT" license-file = "LICENSE.txt" [dependencies] diff --git a/fsm/state_machine_procmacro/Cargo.toml b/fsm/state_machine_procmacro/Cargo.toml index 1bb23e9cb..c4dcf5208 100644 --- a/fsm/state_machine_procmacro/Cargo.toml +++ b/fsm/state_machine_procmacro/Cargo.toml @@ -3,7 +3,6 @@ name = "state_machine_procmacro" version = "0.1.0" authors = ["Spencer Judge "] edition = "2018" -license = "MIT" license-file = "LICENSE.txt" [lib] diff --git a/fsm/state_machine_trait/Cargo.toml b/fsm/state_machine_trait/Cargo.toml index 13b4d46bc..66cad6e21 100644 --- a/fsm/state_machine_trait/Cargo.toml +++ b/fsm/state_machine_trait/Cargo.toml @@ -3,7 +3,6 @@ name = "state_machine_trait" version = "0.1.0" authors = ["Spencer Judge "] edition = "2018" -license = "MIT" license-file = "LICENSE.txt" # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html diff --git a/src/lib.rs b/src/lib.rs index d0379593e..f3de11fff 100644 --- a/src/lib.rs +++ b/src/lib.rs @@ -269,7 +269,7 @@ impl CoreSDK { .collect::>>()?; self.access_machine(run_id, |mgr| { mgr.command_sink.send(cmds)?; - mgr.machines.event_loop(); + mgr.machines.iterate_machines(); Ok(()) })?; Ok(()) diff --git a/src/machines/workflow_machines.rs b/src/machines/workflow_machines.rs index 0a34c6332..2905934f3 100644 --- a/src/machines/workflow_machines.rs +++ b/src/machines/workflow_machines.rs @@ -210,7 +210,7 @@ impl WorkflowMachines { self.current_started_event_id = task_started_event_id; self.set_current_time(time); - self.event_loop(); + self.iterate_machines(); } /// A command event is an event which is generated from a command emitted by a past decision. @@ -379,9 +379,9 @@ impl WorkflowMachines { .expect("We have just ensured this is populated") } - /// Runs the event loop, which consists of grabbing any pending outgoing commands from the - /// workflow, handling them, and preparing them to be sent off to the server. - pub(crate) fn event_loop(&mut self) { + /// Iterate the state machines, which consists of grabbing any pending outgoing commands from + /// the workflow, handling them, and preparing them to be sent off to the server. + pub(crate) fn iterate_machines(&mut self) { let results = self.drive_me.fetch_workflow_iteration_output(); self.handle_driven_results(results);