diff options
| author | levlam <levlam@telegram.org> | 2018-04-07 02:38:28 +0300 |
|---|---|---|
| committer | levlam <levlam@telegram.org> | 2018-04-07 02:38:28 +0300 |
| commit | baa334544ba9ed5266e3f5b64426d41419fcbd13 (patch) | |
| tree | 9a6c996ce12152da2321f64dfd93a6ef29c4ac7a /td/telegram/DelayDispatcher.cpp | |
| parent | 775c2eea25b7f57f76c6e8fbb962eaaa4cb5437b (diff) | |
More fixes.
GitOrigin-RevId: 587cca0a2e3a87c117fa78d59c81d61815e2756d
Diffstat (limited to 'td/telegram/DelayDispatcher.cpp')
| -rw-r--r-- | td/telegram/DelayDispatcher.cpp | 3 |
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()) { |
