... | @@ -193,7 +193,7 @@ std::unique_ptr<coms::Subscriber> subscriber = coms::Subscriber::create(*publish |
... | @@ -193,7 +193,7 @@ std::unique_ptr<coms::Subscriber> subscriber = coms::Subscriber::create(*publish |
|
while (true) {
|
|
while (true) {
|
|
std::optional<std::string> message = subscriber->receive();
|
|
std::optional<std::string> message = subscriber->receive();
|
|
|
|
|
|
// If there is no value then the subscriber will not receive message any more.
|
|
// If there is no value then the subscriber will not receive messages any more.
|
|
if (!message.has_value()) {
|
|
if (!message.has_value()) {
|
|
break;
|
|
break;
|
|
}
|
|
}
|
... | | ... | |