5using System.Threading.Tasks;
11 private readonly TimeSpan timeout;
14 public async Task ExecuteAsync(Func<CancellationToken, Task> action, CancellationToken ct)
16 using CancellationTokenSource Linked = CancellationTokenSource.CreateLinkedTokenSource(ct);
17 Linked.CancelAfter(this.timeout);
18 await action(Linked.Token);
21 public async Task<T>
ExecuteAsync<T>(Func<CancellationToken, Task<T>> action, CancellationToken ct)
23 using CancellationTokenSource Linked = CancellationTokenSource.CreateLinkedTokenSource(ct);
24 Linked.CancelAfter(this.timeout);
25 return await action(Linked.Token);
async Task< T > ExecuteAsync< T >(Func< CancellationToken, Task< T > > action, CancellationToken ct)
Executes an async action producing a value through the policy pipeline.