diff options
author | Marvin W <git@larma.de> | 2023-01-31 15:13:12 +0100 |
---|---|---|
committer | Marvin W <git@larma.de> | 2023-02-07 10:50:45 +0100 |
commit | d76e12b215eb62e4eda5a0f92fbf5c1bd7c1848e (patch) | |
tree | 8037cd613ccea827d8d1895b82a2c0dd65a75a14 /xmpp-vala/src/module/xep/0313_2_message_archive_management.vala | |
parent | 18321ed15ce782ff5d1f24de9f2fb459d714d125 (diff) | |
download | dino-d76e12b215eb62e4eda5a0f92fbf5c1bd7c1848e.tar.gz dino-d76e12b215eb62e4eda5a0f92fbf5c1bd7c1848e.zip |
Add priority for and allow cancellation of outgoing stanzas
Diffstat (limited to 'xmpp-vala/src/module/xep/0313_2_message_archive_management.vala')
-rw-r--r-- | xmpp-vala/src/module/xep/0313_2_message_archive_management.vala | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/xmpp-vala/src/module/xep/0313_2_message_archive_management.vala b/xmpp-vala/src/module/xep/0313_2_message_archive_management.vala index a710a459..3a6d9259 100644 --- a/xmpp-vala/src/module/xep/0313_2_message_archive_management.vala +++ b/xmpp-vala/src/module/xep/0313_2_message_archive_management.vala @@ -61,20 +61,20 @@ namespace Xmpp.MessageArchiveManagement.V2 { return MessageArchiveManagement.create_base_query(stream, MessageArchiveManagement.NS_URI_2, mam_params.query_id, fields); } - public async QueryResult query_archive(XmppStream stream, MamQueryParams mam_params) { + public async QueryResult query_archive(XmppStream stream, MamQueryParams mam_params, Cancellable? cancellable = null) { var query_node = create_base_query(stream, mam_params); if (!mam_params.use_ns2_extended) { query_node.put_node(ResultSetManagement.create_set_rsm_node_before(mam_params.end_id)); } - return yield MessageArchiveManagement.query_archive(stream, MessageArchiveManagement.NS_URI_2, mam_params.mam_server, query_node); + return yield MessageArchiveManagement.query_archive(stream, MessageArchiveManagement.NS_URI_2, mam_params.mam_server, query_node, cancellable); } - public async QueryResult page_through_results(XmppStream stream, MamQueryParams mam_params, QueryResult prev_result) { + public async QueryResult page_through_results(XmppStream stream, MamQueryParams mam_params, QueryResult prev_result, Cancellable? cancellable = null) { var query_node = create_base_query(stream, mam_params); query_node.put_node(ResultSetManagement.create_set_rsm_node_before(prev_result.first)); - return yield MessageArchiveManagement.query_archive(stream, MessageArchiveManagement.NS_URI_2, mam_params.mam_server, query_node); + return yield MessageArchiveManagement.query_archive(stream, MessageArchiveManagement.NS_URI_2, mam_params.mam_server, query_node, cancellable); } } |