Add initial_topic_ variable to avoid confusion

This addresses comment ros-tooling#106 (comment) Signed-off-by: Rufus Wong <[email protected]>
rcywongaa · Jun 13, 2024 · 56eca45 · 56eca45
1 parent 31f49ae
commit 56eca45
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 6 deletions.
diff --git a/topic_tools/src/demux_node.cpp b/topic_tools/src/demux_node.cpp
@@ -30,13 +30,14 @@ DemuxNode::DemuxNode(const rclcpp::NodeOptions & options)
   using std::placeholders::_1;
   using std::placeholders::_2;
 
-  output_topic_ = declare_parameter("initial_topic", "");
+  std::string initial_topic = declare_parameter("initial_topic", "");
   input_topic_ = declare_parameter("input_topic", "~/input");
   lazy_ = false;
   output_topics_ = declare_parameter<std::vector<std::string>>("output_topics");
-  if (output_topic_.empty()) {
-    output_topic_ = output_topics_.front();
+  if (initial_topic.empty()) {
+    initial_topic = output_topics_.front();
   }
+  output_topic_ = initial_topic;
 
   discovery_timer_ = this->create_wall_timer(
     discovery_period_, std::bind(&DemuxNode::make_subscribe_unsubscribe_decisions, this));

diff --git a/topic_tools/src/mux_node.cpp b/topic_tools/src/mux_node.cpp
@@ -29,13 +29,14 @@ MuxNode::MuxNode(const rclcpp::NodeOptions & options)
   using std::placeholders::_1;
   using std::placeholders::_2;
 
-  input_topic_ = declare_parameter("initial_topic", "");
+  std::string initial_topic = declare_parameter("initial_topic", "");
   output_topic_ = declare_parameter("output_topic", "~/selected");
   lazy_ = declare_parameter<bool>("lazy", false);
   input_topics_ = declare_parameter<std::vector<std::string>>("input_topics");
-  if (input_topic_.empty()) {
-    input_topic_ = input_topics_.front();
+  if (initial_topic.empty()) {
+    initial_topic = input_topics_.front();
   }
+  input_topic_ = initial_topic;
 
   discovery_timer_ = this->create_wall_timer(
     discovery_period_,