File tree Expand file tree Collapse file tree 1 file changed +8
-2
lines changed
test/Cnblogs.DashScope.Tests.Shared/Utils Expand file tree Collapse file tree 1 file changed +8
-2
lines changed Original file line number Diff line number Diff line change @@ -96,9 +96,15 @@ public async Task<WebSocketReceiveResult> ReceiveAsync(
96
96
ArraySegment < byte > buffer ,
97
97
CancellationToken cancellationToken )
98
98
{
99
- var jsonTask = Server . Reader . WaitToReadAsync ( cancellationToken ) ;
99
+ var timeout = Task . Delay ( 1000 , cancellationToken ) ;
100
+ var jsonTask = Server . Reader . WaitToReadAsync ( cancellationToken ) . AsTask ( ) ;
100
101
var binaryTask = ServerBuffer . Reader . WaitToReadAsync ( cancellationToken ) ;
101
- await jsonTask ;
102
+ var finishedTask = await Task . WhenAny ( jsonTask , timeout ) ;
103
+ if ( finishedTask == timeout )
104
+ {
105
+ throw new TimeoutException ( "waiting for next socket message timeouts" ) ;
106
+ }
107
+
102
108
if ( binaryTask . IsCompleted )
103
109
{
104
110
var binary = await ServerBuffer . Reader . ReadAsync ( cancellationToken ) ;
You can’t perform that action at this time.
0 commit comments