IConsumer.cs
11 lines
| 262 B
| text/x-csharp
|
CSharpLexer
|
|
r289 | using System.Threading; | |
| using System.Threading.Tasks; | |||
| namespace Implab.Messaging { | |||
| public interface IConsumer<T> { | |||
| T Receive(CancellationToken ct); | |||
| Task<T> ReceiveAsync(CancellationToken ct); | |||
| bool TryReceive(out T message); | |||
| } | |||
| } |
