File tree Expand file tree Collapse file tree 1 file changed +4
-0
lines changed
rclcpp/include/rclcpp/experimental Expand file tree Collapse file tree 1 file changed +4
-0
lines changed Original file line number Diff line number Diff line change @@ -454,6 +454,8 @@ class IntraProcessManager
454454 if (std::next (it) == subscription_ids.end ()) {
455455 // If this is the last subscription, give up ownership
456456 subscription->provide_intra_process_data (std::move (message));
457+ // Last message delivered, break from for loop
458+ break ;
457459 } else {
458460 // Copy the message since we have additional subscriptions to serve
459461 Deleter deleter = message.get_deleter ();
@@ -493,6 +495,8 @@ class IntraProcessManager
493495 if (std::next (it) == subscription_ids.end ()) {
494496 // If this is the last subscription, give up ownership
495497 ros_message_subscription->provide_intra_process_message (std::move (message));
498+ // Last message delivered, break from for loop
499+ break ;
496500 } else {
497501 // Copy the message since we have additional subscriptions to serve
498502 Deleter deleter = message.get_deleter ();
You can’t perform that action at this time.
0 commit comments