prehistoric-systems/FilterLists
1
0
Fork 0
mirror of https://github.com/collinbarrett/FilterLists.git synced 2026-03-11 09:04:27 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

small tidies

Browse source
This commit is contained in:
Collin M. Barrett 2019-06-28 12:05:31 -05:00
parent 088f44272f
commit bffef0c548
1 changed files with 7 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
src/FilterLists.Agent/ListArchiver/DownloadLists.cs
View file

@ -13,12 +13,12 @@ public static class DownloadLists
{
public class Command : IRequest
{
public Command(IEnumerable<ListInfo> lists)
public Command(IEnumerable<ListInfo> listInfo)
{
Lists = lists;
ListInfo = listInfo;
}
public IEnumerable<ListInfo> Lists { get; }
public IEnumerable<ListInfo> ListInfo { get; }
}
public class Handler : AsyncRequestHandler<Command>
@ -27,10 +27,10 @@ public class Handler : AsyncRequestHandler<Command>
private readonly HttpClient _httpClient;
private readonly IMediator _mediator;
public Handler(IMediator mediator, HttpClient httpClient)
public Handler(HttpClient httpClient, IMediator mediator)
{
_mediator = mediator;
_httpClient = httpClient;
_mediator = mediator;
}
// https://stackoverflow.com/a/22492731/2343739
@ -42,11 +42,11 @@ protected override async Task Handle(Command request, CancellationToken cancella
);
var buffer = new BufferBlock<ListDownload>();
downloader.LinkTo(buffer);
foreach (var list in request.Lists)
foreach (var list in request.ListInfo)
await downloader.SendAsync(list, cancellationToken);
downloader.Complete();
foreach (var _ in request.Lists)
foreach (var _ in request.ListInfo)
{
var listDownload = await buffer.ReceiveAsync(cancellationToken);
await _mediator.Send(new DownloadList.Command(listDownload), cancellationToken);