Skip to content

Commit 6db6803

Browse files
committed
UPD | finish priorities
1 parent a0120ff commit 6db6803

2 files changed

Lines changed: 2 additions & 2 deletions

File tree

src/ManapiGrpc.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1687,7 +1687,7 @@ manapi::future<manapi::status> manapi::net::wgrpc::server::start(std::move_only_
16871687

16881688
try {
16891689
this->data_->finishid = manapi::async::current()->eventloop()->subscribe_finish(
1690-
std::numeric_limits<int>::min(),
1690+
-1,
16911691
[data = this->data_] () -> manapi::future<> {
16921692
co_await data->ctx.storage().unsubscribe(std::move(data->worker));
16931693
co_await server::stop_(data);

src/ManapiHttp.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -72,7 +72,7 @@ manapi::future<manapi::status> manapi::net::http::server::start() {
7272
co_return status_already_exists("already running");
7373
}
7474

75-
data2->event_id = async::current()->eventloop()->subscribe_finish(std::numeric_limits<int>::min(), [data2] ()
75+
data2->event_id = async::current()->eventloop()->subscribe_finish(-1, [data2] ()
7676
-> future<> {
7777
auto res = co_await stop_(data2, true);
7878
manapi_log_trace(manapi::debug::LOG_TRACE_HIGH, "http:Stop status=%.*s", res.msg().size(), res.msg().data());

0 commit comments

Comments
 (0)