src/sendq.cpp
@@ -34,17 +34,9 @@ if (info.on_expire_) { info.on_expire_(info.data_); } if (info.data_.index() == 0) { boost::variant2::get<0>(info.data_).Release(); } } auto SendData = [&](Data &d) { auto TrySend = [&](auto &&data) { return mq.TrySend(remote, data); }; return boost::variant2::visit(TrySend, pos->data().data_); }; while (pos != arr.end() && SendData(pos->data().data_)) { while (pos != arr.end() && mq.TrySend(remote, pos->data().data_)) { ++pos; }