rm SO link (significantly changed)

This commit is contained in:
Collin M. Barrett 2019-06-28 15:54:06 -05:00
parent 1b12ec889e
commit b25dcf6903

View file

@ -29,7 +29,6 @@ public Handler(IMediator mediator)
_mediator = mediator;
}
// https://stackoverflow.com/a/22492731/2343739
protected override async Task Handle(Command request, CancellationToken cancellationToken)
{
var downloader = new ActionBlock<ListInfo>(
@ -37,7 +36,7 @@ protected override async Task Handle(Command request, CancellationToken cancella
new ExecutionDataflowBlockOptions {MaxDegreeOfParallelism = MaxDegreeOfParallelism}
);
foreach (var list in request.ListInfo)
await downloader.SendAsync(list, cancellationToken);
await downloader.SendAsync(list, cancellationToken);
downloader.Complete();
await downloader.Completion;
}