qTox
Version: nightly | Commit: bc751c8e1cac455f9690654fcfe0f560d2d7dfdd
|
Go to the documentation of this file.
27 #include "util/compatiblerecursivemutex.h"
68 template <
class ReceiptT>
74 auto receivedReceiptIt = std::find(
90 unackedMessageIt->second.completionFn(
true);
98 std::vector<OfflineMessage>
clear()
100 auto ret = std::vector<OfflineMessage>();
103 std::back_inserter(ret),
104 [] (
const std::pair<ReceiptT, OfflineMessage>& pair) {
105 return std::move(pair.second);
ReceiptResolver< ExtendedReceiptNum > extendedReceiptResolver
void notifyReceiptReceived(ReceiptT receipt)
OfflineMsgEngine()=default
std::vector< ReceiptT > receivedReceipts
CompatibleRecursiveMutex mutex
std::vector< OfflineMessage > clear()
CompletionFn completionFn
void addSentCoreMessage(ReceiptNum receipt, Message const &message, CompletionFn completionCallback)
Add a message which has been saved to history, and which has been sent to the peer.
void onReceiptReceived(ReceiptNum receipt)
Notification that the message is now delivered.
NamedType< uint32_t, struct ExtendedReceiptNumTag, Orderable > ExtendedReceiptNum
void addUnsentMessage(Message const &message, CompletionFn completionCallback)
Add a message which has been saved to history, but not sent yet to the peer.
std::vector< RemovedMessage > removeAllMessages()
Removes all messages which are being tracked.
void addSentExtendedMessage(ExtendedReceiptNum receipt, Message const &message, CompletionFn completionCallback)
std::function< void(bool)> CompletionFn
std::chrono::time_point< std::chrono::steady_clock > authorshipTime
void onExtendedReceiptReceived(ExtendedReceiptNum receipt)
NamedType< uint32_t, struct ReceiptNumTag, Orderable > ReceiptNum
ReceiptResolver< ReceiptNum > receiptResolver
void notifyMessageSent(ReceiptT receipt, OfflineMessage const &message)
std::map< ReceiptT, OfflineMessage > unAckedMessages
std::vector< OfflineMessage > unsentMessages