set run_forver (keepalive) automatically if there are input actions

Author: cmnrd

examples/count/main.cc

@@ -37,7 +37,7 @@ class Count : public Reactor {
 };
 
 auto main() -> int {
-  Environment env{4, true};
+  Environment env{4};
 
   Count count{&env};
   env.assemble();

examples/hello/main.cc

@@ -31,7 +31,7 @@ class Hello : public Reactor {
 };
 
 auto main() -> int {
-  Environment env{4, false, false, 5s};
+  Environment env{4, false, 5s};
 
   Hello hello{&env};
   env.assemble();

include/reactor-cpp/environment.hh

@@ -37,7 +37,7 @@ private:
   const log::NamedLogger log_;
   const unsigned int num_workers_{default_number_worker};
   unsigned int max_reaction_index_{default_max_reaction_index};
-  const bool run_forever_{default_run_forever};
+  bool run_forever_{default_run_forever};
   const bool fast_fwd_execution_{default_fast_fwd_execution};
 
   std::set<Reactor*> top_level_reactors_{};
@@ -67,8 +67,8 @@ private:
   auto startup(const TimePoint& start_time) -> std::thread;
 
 public:
-  explicit Environment(unsigned int num_workers, bool run_forever = default_run_forever,
-                       bool fast_fwd_execution = default_fast_fwd_execution, const Duration& timeout = Duration::max());
+  explicit Environment(unsigned int num_workers, bool fast_fwd_execution = default_fast_fwd_execution,
+                       const Duration& timeout = Duration::max());
   explicit Environment(const std::string& name, Environment* containing_environment);
 
   auto name() -> const std::string& { return name_; }

lib/environment.cc

@@ -23,10 +23,9 @@
 
 namespace reactor {
 
-Environment::Environment(unsigned int num_workers, bool run_forever, bool fast_fwd_execution, const Duration& timeout)
+Environment::Environment(unsigned int num_workers, bool fast_fwd_execution, const Duration& timeout)
     : log_("Environment")
     , num_workers_(num_workers)
-    , run_forever_(run_forever)
     , fast_fwd_execution_(fast_fwd_execution)
     , top_environment_(this)
     , scheduler_(this)
@@ -36,7 +35,6 @@ Environment::Environment(const std::string& name, Environment* containing_enviro
     : name_(name)
     , log_("Environment " + name)
     , num_workers_(containing_environment->num_workers_)
-    , run_forever_(containing_environment->run_forever_)
     , fast_fwd_execution_(containing_environment->fast_fwd_execution_)
     , containing_environment_(containing_environment)
     , top_environment_(containing_environment_->top_environment_)
@@ -56,6 +54,7 @@ void Environment::register_input_action(BaseAction* action) {
   reactor_assert(action != nullptr);
   validate(this->phase() == Phase::Construction, "Input actions may only be registered during construction phase!");
   reactor_assert(input_actions_.insert(action).second);
+  run_forever_ = true;
 }
 
 void recursive_assemble(Reactor* container) { // NOLINT