public async Task<Stream> GetAsync(Uri remoteAddress, string path, CancellationToken cancellationToken = default)
{
ResiliencePipeline<HttpResponseMessage> pipeline = resiliencePipeline.GetPipeline<HttpResponseMessage>("get-pipeline");
UriBuilder endpoint = new(remoteAddress) { Path = path };
HttpResponseMessage reqResp = await pipeline.ExecuteAsync(async token => await _httpClient.GetAsync(endpoint.Uri, token), cancellationToken);
await reqResp.Content.ReadAsStreamAsync(cancellationToken);
}
public async Task<Stream> GetAsync(Uri remoteAddress, string path, CancellationToken cancellationToken = default)
{
ResiliencePipeline<HttpResponseMessage> pipeline = resiliencePipeline.GetPipeline<HttpResponseMessage>("get-pipeline");
UriBuilder endpoint = new(remoteAddress) { Path = path };
HttpResponseMessage reqResp = await pipeline.ExecuteAsync(async token => await _httpClient.GetAsync(endpoint.Uri, token), cancellationToken);
await reqResp.Content.ReadAsStreamAsync(cancellationToken);
}