Skip to content

Commit 627c936

Browse files
authored
fix: System.FormatException #333 (#334)
1 parent 91f6696 commit 627c936

File tree

1 file changed

+6
-2
lines changed

1 file changed

+6
-2
lines changed

src/Fusillade/RateLimitedHttpMessageHandler.cs

+6-2
Original file line numberDiff line numberDiff line change
@@ -168,21 +168,25 @@ protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage reques
168168
if (cacheResult != null && resp.Content != null)
169169
{
170170
var ms = new MemoryStream();
171+
#if NET5_0_OR_GREATER
172+
var stream = await resp.Content.ReadAsStreamAsync(realToken.Token).ConfigureAwait(false);
173+
#else
171174
var stream = await resp.Content.ReadAsStreamAsync().ConfigureAwait(false);
175+
#endif
172176
await stream.CopyToAsync(ms, 32 * 1024, realToken.Token).ConfigureAwait(false);
173177

174178
realToken.Token.ThrowIfCancellationRequested();
175179

176180
var newResp = new HttpResponseMessage();
177181
foreach (var kvp in resp.Headers)
178182
{
179-
newResp.Headers.Add(kvp.Key, kvp.Value);
183+
newResp.Headers.TryAddWithoutValidation(kvp.Key, kvp.Value);
180184
}
181185

182186
var newContent = new ByteArrayContent(ms.ToArray());
183187
foreach (var kvp in resp.Content.Headers)
184188
{
185-
newContent.Headers.Add(kvp.Key, kvp.Value);
189+
newContent.Headers.TryAddWithoutValidation(kvp.Key, kvp.Value);
186190
}
187191

188192
newResp.Content = newContent;

0 commit comments

Comments
 (0)