diff options
| author | levlam <levlam@telegram.org> | 2022-04-13 17:40:12 +0300 |
|---|---|---|
| committer | levlam <levlam@telegram.org> | 2022-04-13 17:40:12 +0300 |
| commit | 163e7393024053b5ea986615d554cb6b2d8a6ed1 (patch) | |
| tree | 8d46577908aa9be2a11683094a78727e062018c9 /test/secret.cpp | |
| parent | 4612910a14f0a75e800eb4898408e5c441a682c3 (diff) | |
Add set_promises/fail_promises helper functions.
Diffstat (limited to 'test/secret.cpp')
| -rw-r--r-- | test/secret.cpp | 8 |
1 files changed, 3 insertions, 5 deletions
diff --git a/test/secret.cpp b/test/secret.cpp index c2cb0c568..bc1d03a91 100644 --- a/test/secret.cpp +++ b/test/secret.cpp @@ -433,7 +433,7 @@ class FakeBinlog final has_request_sync = false; auto pos = static_cast<size_t>(Random::fast_uint64() % pending_events_.size()); // pos = pending_events_.size() - 1; - std::vector<Promise<>> promises; + td::vector<Promise<Unit>> promises; for (size_t i = 0; i <= pos; i++) { auto &pending = pending_events_[i]; auto event = std::move(pending.event); @@ -444,9 +444,7 @@ class FakeBinlog final append(promises, std::move(pending.promises_)); } pending_events_.erase(pending_events_.begin(), pending_events_.begin() + pos + 1); - for (auto &promise : promises) { - promise.set_value(Unit()); - } + set_promises(promises); for (auto &event : pending_events_) { if (event.sync_flag) { @@ -470,7 +468,7 @@ class FakeBinlog final struct PendingEvent { BinlogEvent event; bool sync_flag = false; - std::vector<Promise<>> promises_; + td::vector<Promise<Unit>> promises_; }; std::vector<PendingEvent> pending_events_; |
