IConsumer.cs
11 lines
| 262 B
| text/x-csharp
|
CSharpLexer
cin
|
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); | |||
} | |||
} |