Давайте я объясню, что имел в виду @Pavel Mayorov.
Когда вы получаете поток, вы не должны копировать его одним махом через CopyToAsync
, потому что вы не получаете информации о протекании операции. Поэтому вам нужно организовать копирование между потоками вручную.
Маленькая подробность: если мы сразу получаем поток, то у нас не выйдет узнать размер файла. Поэтому возьмём не поток, а весь HttpResponseMessage
, а из него уж получим и размер, и Stream
.
Получаем вот такой код:
static async Task DownloadWithProgress(HttpClient c, Uri uri, string savePath,
IProgress<(long downloaded, long? total)> progress)
{
// получаем http-ответ
using (var resp = await c.GetAsync(uri, HttpCompletionOption.ResponseHeadersRead))
{
// проверяем успешность запроса
if (!resp.IsSuccessStatusCode)
throw new InvalidOperationException($"Download failed: {resp.ReasonPhrase}");
using (var content = resp.Content)
{
// запрашиваем длину
var total = content.Headers.ContentLength;
// получаем потоки
using (var instr = await content.ReadAsStreamAsync())
using (var outstr = File.Create(savePath))
{
// и копируем один в другой вручную, через буфер
byte[] buffer = new byte[1024 * 1024]; // подберите размер сами!
long readySoFar = 0;
progress.Report((readySoFar, total));
while (true)
{
var actuallyRead = await instr.ReadAsync(buffer, 0, buffer.Length);
if (actuallyRead == 0)
break;
await outstr.WriteAsync(buffer, 0, actuallyRead);
readySoFar += actuallyRead;
// оправляем отчёт о прогрессе копирования
progress.Report((readySoFar, total));
}
}
}
}
}
Для случая UWP вам придётся, вероятно, заменить string savePath
на IStorageFile newFile
и File.Create(savePath)
на await newFile.OpenStreamForWriteAsync()
(мне не на чем проверить).
Пользоваться, например, так:
var uri = ...;
var progress = new Progress<(long downloaded, long? total)>(p => Console.WriteLine(
p.total.HasValue ?
$"Downloaded {p.downloaded} ({(double)p.downloaded / p.total.Value:0.00%})" :
$"Downloaded {p.downloaded} of ?"));
var savePath = ...;
using (var c = new HttpClient())
await DownloadWithProgress(c, uri, savePath, progress);