File tree 1 file changed +3
-0
lines changed
src/libraries/System.Net.Http/tests/FunctionalTests
1 file changed +3
-0
lines changed Original file line number Diff line number Diff line change @@ -1626,6 +1626,7 @@ public async Task DuplexStreaming_AbortByServer_StreamingCancelled(bool graceful
1626
1626
public async Task ServerSendsTrailingHeaders_Success ( )
1627
1627
{
1628
1628
using Http3LoopbackServer server = CreateHttp3LoopbackServer ( ) ;
1629
+ SemaphoreSlim clientFinishedSemaphore = new SemaphoreSlim ( 0 ) ;
1629
1630
1630
1631
Task serverTask = Task . Run ( async ( ) =>
1631
1632
{
@@ -1636,6 +1637,7 @@ public async Task ServerSendsTrailingHeaders_Success()
1636
1637
await requestStream . ReadRequestDataAsync ( ) ;
1637
1638
await requestStream . SendResponseAsync ( isFinal : false ) ;
1638
1639
await requestStream . SendResponseHeadersAsync ( null , new [ ] { new HttpHeaderData ( "MyHeader" , "MyValue" ) } ) ;
1640
+ await clientFinishedSemaphore . WaitAsync ( TimeSpan . FromSeconds ( 20 ) ) ;
1639
1641
} ) ;
1640
1642
1641
1643
Task clientTask = Task . Run ( async ( ) =>
@@ -1655,6 +1657,7 @@ public async Task ServerSendsTrailingHeaders_Success()
1655
1657
( string key , IEnumerable < string > value ) = Assert . Single ( response . TrailingHeaders ) ;
1656
1658
Assert . Equal ( "MyHeader" , key ) ;
1657
1659
Assert . Equal ( "MyValue" , Assert . Single ( value ) ) ;
1660
+ clientFinishedSemaphore . Release ( ) ;
1658
1661
} ) ;
1659
1662
1660
1663
await new [ ] { clientTask , serverTask } . WhenAllOrAnyFailed ( 200_000 ) ;
You can’t perform that action at this time.
0 commit comments