summaryrefslogtreecommitdiff
path: root/src/mbgl/actor/mailbox.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mbgl/actor/mailbox.cpp')
-rw-r--r--src/mbgl/actor/mailbox.cpp12
1 files changed, 9 insertions, 3 deletions
diff --git a/src/mbgl/actor/mailbox.cpp b/src/mbgl/actor/mailbox.cpp
index dfe0520790..070e14bdb0 100644
--- a/src/mbgl/actor/mailbox.cpp
+++ b/src/mbgl/actor/mailbox.cpp
@@ -27,7 +27,7 @@ void Mailbox::open(Scheduler& scheduler_) {
}
if (!queue.empty()) {
- (*scheduler)->schedule(shared_from_this());
+ (*scheduler)->schedule(makeClosure(shared_from_this()));
}
}
@@ -57,7 +57,7 @@ void Mailbox::push(std::unique_ptr<Message> message) {
bool wasEmpty = queue.empty();
queue.push(std::move(message));
if (wasEmpty && scheduler) {
- (*scheduler)->schedule(shared_from_this());
+ (*scheduler)->schedule(makeClosure(shared_from_this()));
}
}
@@ -84,14 +84,20 @@ void Mailbox::receive() {
(*message)();
if (!wasEmpty) {
- (*scheduler)->schedule(shared_from_this());
+ (*scheduler)->schedule(makeClosure(shared_from_this()));
}
}
+// static
void Mailbox::maybeReceive(std::weak_ptr<Mailbox> mailbox) {
if (auto locked = mailbox.lock()) {
locked->receive();
}
}
+// static
+std::function<void()> Mailbox::makeClosure(std::weak_ptr<Mailbox> mailbox) {
+ return [mailbox]() { maybeReceive(mailbox); };
+}
+
} // namespace mbgl