IqResponse.cs

using System;
using System.Collections.Generic;
using System.Threading.Tasks;
 
namespace Waher.Networking.XMPP.Server
{
    public class IqResponse
    {
        private readonly TaskCompletionSource<KeyValuePair<string, bool>> xml = new TaskCompletionSource<KeyValuePair<string, bool>>();
        private readonly DateTime expiresUtc;
        private readonly string key;
        private bool resultSet = false;
 
        internal IqResponse(string Key, DateTime ExpiresUtc)
        {
            this.key = Key;
            this.expiresUtc = ExpiresUtc;
        }
 
        public string Key => this.key;
 
        public DateTime ExpiresUtc => this.expiresUtc;
 
        internal bool SetResult(string Xml, bool Ok)
        {
            lock (this)
            {
                if (this.resultSet)
                    return false;
 
                this.resultSet = true;
                this.xml.TrySetResult(new KeyValuePair<string, bool>(Xml, Ok));
 
                return true;
            }
        }
 
        public async Task<KeyValuePair<string, bool>> GetResponse()
        {
            return await this.xml.Task;
        }
    }
}