view Implab/Messaging/IProducer.cs @ 281:e0916ddc9950 v3 tip

code cleanup and refactoring
author cin
date Fri, 01 Jun 2018 21:35:24 +0300
parents 7c7e9ad6fe4a
children
line wrap: on
line source

using System.Collections.Generic;
using System.Threading;
using System.Threading.Tasks;

namespace Implab.Messaging {
    public interface IProducer<T> {
        void PostMessage(T message, CancellationToken ct);

        Task PostMessageAsync(T message, CancellationToken ct);

        void PostMessages(IEnumerable<T> messages, CancellationToken ct);

        Task PostMessagesAsync(IEnumerable<T> messages, CancellationToken ct);
    }
}