void MetricsCollector::SubscribeAllTopics()

in cloudwatch_metrics_collector/src/metrics_collector.cpp [72:83]

• 12 lines of code
• 2 McCabe index (conditional complexity)

void MetricsCollector::SubscribeAllTopics()
{
  for (const auto & topic_name : topics_) {
    std::shared_ptr<rclcpp::SubscriptionBase> sub =
      node_->create_subscription<ros_monitoring_msgs::msg::MetricList>(
        topic_name, kNodeSubQueueSize,
        [this](ros_monitoring_msgs::msg::MetricList::UniquePtr metric_list_msg) -> void {
          this->RecordMetrics(std::move(metric_list_msg));
        });
    subscriptions_.push_back(std::move(sub));
  }
}