diff options
Diffstat (limited to 'libs/tdlib/td/td/telegram/net/NetQueryDelayer.h')
-rw-r--r-- | libs/tdlib/td/td/telegram/net/NetQueryDelayer.h | 35 |
1 files changed, 35 insertions, 0 deletions
diff --git a/libs/tdlib/td/td/telegram/net/NetQueryDelayer.h b/libs/tdlib/td/td/telegram/net/NetQueryDelayer.h new file mode 100644 index 0000000000..5083434004 --- /dev/null +++ b/libs/tdlib/td/td/telegram/net/NetQueryDelayer.h @@ -0,0 +1,35 @@ +// +// Copyright Aliaksei Levin (levlam@telegram.org), Arseny Smirnov (arseny30@gmail.com) 2014-2018 +// +// Distributed under the Boost Software License, Version 1.0. (See accompanying +// file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt) +// +#pragma once +#include "td/telegram/net/NetQuery.h" + +#include "td/actor/actor.h" +#include "td/actor/SignalSlot.h" + +#include "td/utils/Container.h" + +namespace td { +class NetQueryDelayer : public Actor { + public: + explicit NetQueryDelayer(ActorShared<> parent) : parent_(std::move(parent)) { + } + void delay(NetQueryPtr query); + + private: + struct QuerySlot { + NetQueryPtr query_; + Slot timeout_; + }; + Container<QuerySlot> container_; + ActorShared<> parent_; + void wakeup() override; + + void on_slot_event(uint64 id); + + void tear_down() override; +}; +} // namespace td |