| 630 | } |
| 631 | |
| 632 | void System::checkDelayed() { |
| 633 | for (auto i = _settingWaiters.begin(); i != _settingWaiters.end();) { |
| 634 | const auto remove = [&] { |
| 635 | const auto thread = i->first; |
| 636 | const auto peer = thread->peer(); |
| 637 | const auto fullId = FullMsgId(peer->id, i->second.key.messageId); |
| 638 | const auto item = thread->owner().message(fullId); |
| 639 | if (!item) { |
| 640 | return true; |
| 641 | } |
| 642 | const auto state = computeSkipState({ |
| 643 | .item = item, |
| 644 | .reactionOrVoteSender = i->second.reactionOrVoteSender, |
| 645 | .type = i->second.type, |
| 646 | }); |
| 647 | if (state.value == SkipState::Skip) { |
| 648 | return true; |
| 649 | } else if (state.value == SkipState::Unknown |
| 650 | || !item->notificationReady()) { |
| 651 | return false; |
| 652 | } |
| 653 | _waiters.emplace(i->first, i->second); |
| 654 | return true; |
| 655 | }(); |
| 656 | if (remove) { |
| 657 | i = _settingWaiters.erase(i); |
| 658 | } else { |
| 659 | ++i; |
| 660 | } |
| 661 | } |
| 662 | _waitTimer.cancel(); |
| 663 | showNext(); |
| 664 | } |
| 665 | |
| 666 | void System::showGrouped() { |
| 667 | Expects(_manager != nullptr); |
no test coverage detected