aboutsummaryrefslogtreecommitdiffhomepage
path: root/td/telegram/DelayDispatcher.cpp
diff options
context:
space:
mode:
authorlevlam <levlam@telegram.org>2018-04-07 02:38:28 +0300
committerlevlam <levlam@telegram.org>2018-04-07 02:38:28 +0300
commitbaa334544ba9ed5266e3f5b64426d41419fcbd13 (patch)
tree9a6c996ce12152da2321f64dfd93a6ef29c4ac7a /td/telegram/DelayDispatcher.cpp
parent775c2eea25b7f57f76c6e8fbb962eaaa4cb5437b (diff)
More fixes.
GitOrigin-RevId: 587cca0a2e3a87c117fa78d59c81d61815e2756d
Diffstat (limited to 'td/telegram/DelayDispatcher.cpp')
-rw-r--r--td/telegram/DelayDispatcher.cpp3
1 files changed, 2 insertions, 1 deletions
diff --git a/td/telegram/DelayDispatcher.cpp b/td/telegram/DelayDispatcher.cpp
index 130d3c661..f42ee6622 100644
--- a/td/telegram/DelayDispatcher.cpp
+++ b/td/telegram/DelayDispatcher.cpp
@@ -14,11 +14,12 @@ namespace td {
void DelayDispatcher::send_with_callback(NetQueryPtr query, ActorShared<NetQueryCallback> callback) {
send_with_callback_and_delay(std::move(query), std::move(callback), default_delay_);
}
+
void DelayDispatcher::send_with_callback_and_delay(NetQueryPtr query, ActorShared<NetQueryCallback> callback,
double delay) {
queue_.push({std::move(query), std::move(callback), delay});
loop();
-} // namespace td
+}
void DelayDispatcher::loop() {
if (!wakeup_at_.is_in_past()) {