VSadov/Satori
1
0
Fork 0
mirror of https://github.com/VSadov/Satori.git synced 2025-06-10 18:11:04 +09:00
Code Activity

Fix flaky Json+Pipe test (#102412)

Browse source
This commit is contained in:
Brennan 2024-05-20 03:21:14 -07:00 • committed by GitHub
parent 8fcadc6eb1
commit 794b0c2a9e
Signed by: github
GPG key ID: B5690EEEBB952194
1 changed files with 4 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

9
src/libraries/System.Text.Json/tests/System.Text.Json.Tests/Serialization/Pipe.WriteTests.cs
View file

@ -4,7 +4,6 @@
using System.Buffers;
using System.Collections.Generic;
using System.IO.Pipelines;
using System.Runtime.CompilerServices;
using System.Text.Json.Serialization.Metadata;
using System.Threading;
using System.Threading.Tasks;
@ -56,6 +55,7 @@ namespace System.Text.Json.Serialization.Tests
[Fact]
public async Task CancelPendingFlushDuringBackpressureThrows()
{
int i = 0;
Pipe pipe = new Pipe(new PipeOptions(pauseWriterThreshold: 10, resumeWriterThreshold: 5));
await pipe.Writer.WriteAsync("123456789"u8.ToArray());
Task serializeTask = JsonSerializer.SerializeAsync(pipe.Writer, GetNumbersAsync());
@ -68,13 +68,12 @@ namespace System.Text.Json.Serialization.Tests
ReadResult result = await pipe.Reader.ReadAsync();
// Technically this check is not needed, but helps confirm behavior, that Pipe had written but was waiting for flush to continue.
// result.Buffer: 123456789[0
Assert.Equal(11, result.Buffer.Length);
// result.Buffer: 123456789[0...
Assert.Equal(10 + i - 1, result.Buffer.Length);
pipe.Reader.AdvanceTo(result.Buffer.End);
static async IAsyncEnumerable<int> GetNumbersAsync()
async IAsyncEnumerable<int> GetNumbersAsync()
{
int i = 0;
while (true)
{
await Task.Delay(10);