ISubscription.cs

using System;
using System.Threading.Tasks;
 
namespace Datalayer
{
#if NETSTANDARD2_0
    public static class Subscription
    {
        #region Public Subscription Consts
 
        public static readonly uint DefaultKeepaliveIntervalMillis = 60000;
 
        public static readonly uint DefaultPublishIntervalMillis = 1000;
 
        public static readonly uint DefaultErrorIntervalMillis = 10000;
 
        public static readonly ulong DefaultSamplingIntervalMicros = 1000000;
 
        #endregion
    }
 
    public delegate void DataChangedEventHandler(ISubscription subscription, IDataChangedEventArgs args);
#endif
 
    public interface ISubscription : INativeDisposable
    {
#if !NETSTANDARD2_0
 
        #region Public Subscription Consts
 
        public static readonly uint DefaultKeepaliveIntervalMillis = 60000;
 
        public static readonly uint DefaultPublishIntervalMillis = 1000;
 
        public static readonly uint DefaultErrorIntervalMillis = 10000;
 
        public static readonly ulong DefaultSamplingIntervalMicros = 1000000;
 
        #endregion
 
        delegate void DataChangedEventHandler(ISubscription subscription, IDataChangedEventArgs args);
#endif
 
        event DataChangedEventHandler DataChanged;
 
        IClient Client { get; }
 
        string Id { get; }
 
        object UserData { get; }
 
        DLR_RESULT Subscribe(string address);
 
        Task<ISubscriptionAsyncResult> SubscribeAsync(string address);
 
        DLR_RESULT SubscribeMulti(string[] addresses);
 
        Task<ISubscriptionAsyncResult> SubscribeMultiAsync(string[] addresses);
 
        DLR_RESULT Unsubscribe(string address);
 
        Task<ISubscriptionAsyncResult> UnsubscribeAsync(string address);
 
        DLR_RESULT UnsubscribeMulti(string[] addresses);
 
        Task<ISubscriptionAsyncResult> UnsubscribeMultiAsync(string[] addresses);
 
        DLR_RESULT UnsubscribeAll();
 
        Task<ISubscriptionAsyncResult> UnsubscribeAllAsync();
    }
}