annotate Implab/Messaging/IProducer.cs @ 262:f1696cdc3d7a
v3 v3.0.8
Added IInitializable.Initialize() overload
Added IRunnable.Start(), IRunnable.Start() overloads
Fixed cancellation of the current operation when Stop() is called
More tests
author
cin
date
Mon, 16 Apr 2018 02:12:39 +0300 (2018-04-15)
parents
7c7e9ad6fe4a
children
rev
line source
250
+ − 1 using System.Collections.Generic;
+ − 2 using System.Threading;
+ − 3 using System.Threading.Tasks;
+ − 4
+ − 5 namespace Implab.Messaging {
+ − 6 public interface IProducer<T> {
251
+ − 7 void PostMessage(T message, CancellationToken ct);
+ − 8
250
+ − 9 Task PostMessageAsync(T message, CancellationToken ct);
+ − 10
251
+ − 11 void PostMessages(IEnumerable<T> messages, CancellationToken ct);
+ − 12
250
+ − 13 Task PostMessagesAsync(IEnumerable<T> messages, CancellationToken ct);
+ − 14 }
+ − 15 }