MCPcopy Create free account
hub / github.com/AlexInLog/ReactivePlusPlus / dispatch_impl

Method dispatch_impl

src/rpp/rpp/schedulers/run_loop.hpp:156–166  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

154
155 private:
156 void dispatch_impl(bool wait) const
157 {
158 if (auto top = m_state->pop(wait))
159 {
160 if (top->is_disposed())
161 return;
162
163 if (const auto timepoint = (*top)())
164 m_state->emplace_and_notify(timepoint.value(), std::move(top));
165 }
166 }
167
168 private:
169 std::shared_ptr<state_t> m_state = std::make_shared<state_t>();

Callers

nothing calls this directly

Calls 3

emplace_and_notifyMethod · 0.80
popMethod · 0.45
is_disposedMethod · 0.45

Tested by

no test coverage detected