diff --git a/reactor.hh b/reactor.hh index 59711def46..e9ae6db93f 100644 --- a/reactor.hh +++ b/reactor.hh @@ -409,6 +409,14 @@ promise::get_future() return future(_state); } +inline +future +promise::get_future() +{ + assert(!_state->_future); + return future(_state); +} + using accept_result = std::tuple; struct listen_options { @@ -815,7 +823,12 @@ void future_state::make_ready() { } } - +inline +void future_state::make_ready() { + if (_task) { + the_reactor.add_task(std::move(_task)); + } +} #if 0 future> read_until(size_t limit, const CharType* eol, size_t eol_len);