Commit d43850ee authored by Jakob Otto's avatar Jakob Otto

Remove unnecessary if condition

parent 694577a5
...@@ -101,12 +101,9 @@ public: ...@@ -101,12 +101,9 @@ public:
CAF_LOG_TRACE(CAF_ARG2("handle", this->handle_.id) CAF_LOG_TRACE(CAF_ARG2("handle", this->handle_.id)
<< CAF_ARG2("queue-size", this->packet_queue_.size())); << CAF_ARG2("queue-size", this->packet_queue_.size()));
auto get_messages = [&] { auto get_messages = [&] {
if (packet_queue_.empty()) { for (auto msg = manager.next_message(); msg != nullptr;
for (auto msg = manager.next_message(); msg != nullptr; msg = manager.next_message())
msg = manager.next_message()) { this->next_layer_.write_message(*this, std::move(msg));
this->next_layer_.write_message(*this, std::move(msg));
}
}
return !packet_queue_.empty(); return !packet_queue_.empty();
}; };
while (write_some() && get_messages()) while (write_some() && get_messages())
......
...@@ -108,12 +108,9 @@ public: ...@@ -108,12 +108,9 @@ public:
CAF_LOG_TRACE(CAF_ARG2("handle", this->handle().id) CAF_LOG_TRACE(CAF_ARG2("handle", this->handle().id)
<< CAF_ARG2("queue-size", write_queue_.size())); << CAF_ARG2("queue-size", write_queue_.size()));
auto get_messages = [&] { auto get_messages = [&] {
if (write_queue_.empty()) { for (auto msg = manager.next_message(); msg != nullptr;
for (auto msg = manager.next_message(); msg != nullptr; msg = manager.next_message())
msg = manager.next_message()) { this->next_layer_.write_message(*this, std::move(msg));
this->next_layer_.write_message(*this, std::move(msg));
}
}
return !write_queue_.empty(); return !write_queue_.empty();
}; };
while (write_some() && get_messages()) while (write_some() && get_messages())
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment