IProducer.cs
14 lines
| 440 B
| text/x-csharp
|
CSharpLexer
cin
|
r250 | using System.Collections.Generic; | |
using System.Threading; | |||
using System.Threading.Tasks; | |||
namespace Implab.Messaging { | |||
public interface IProducer<T> { | |||
cin
|
r251 | void PostMessage(T message, CancellationToken ct); | |
cin
|
r250 | Task PostMessageAsync(T message, CancellationToken ct); | |
cin
|
r251 | void PostMessages(IEnumerable<T> messages, CancellationToken ct); | |
cin
|
r250 | Task PostMessagesAsync(IEnumerable<T> messages, CancellationToken ct); | |
} | |||
} |