233 references to DefaultTimeout
InMemory.FunctionalTests (40)
Http2\Http2ConnectionTests.cs (1)
5677
var result = await context.Request.BodyReader.ReadAsync().
DefaultTimeout
();
Http3\Http3ConnectionTests.cs (2)
188
Assert.Null(await Http3Api.MultiplexedConnectionContext.AcceptAsync().
DefaultTimeout
());
414
var maxFieldSetting = await Http3Api.ServerReceivedSettingsReader.ReadAsync().
DefaultTimeout
();
Http3\Http3StreamTests.cs (9)
2775
var outboundControlStream = await Http3Api.CreateControlStream().
DefaultTimeout
();
2782
var invalidStream = await Http3Api.CreateControlStream(typeId).
DefaultTimeout
();
2795
}, endStream: true).
DefaultTimeout
();
2797
await requestStream.ExpectHeadersAsync().
DefaultTimeout
();
2816
var maxFieldSetting = await Http3Api.ServerReceivedSettingsReader.ReadAsync().
DefaultTimeout
();
2827
}, endStream: true).
DefaultTimeout
();
3246
var fieldSetting = await Http3Api.ServerReceivedSettingsReader.ReadAsync().
DefaultTimeout
();
3251
fieldSetting = await Http3Api.ServerReceivedSettingsReader.ReadAsync().
DefaultTimeout
();
3255
fieldSetting = await Http3Api.ServerReceivedSettingsReader.ReadAsync().
DefaultTimeout
();
Http3\Http3TimeoutTests.cs (22)
25
var controlStream = await Http3Api.GetInboundControlStream().
DefaultTimeout
();
26
await controlStream.ExpectSettingsAsync().
DefaultTimeout
();
42
var controlStream = await Http3Api.GetInboundControlStream().
DefaultTimeout
();
43
await controlStream.ExpectSettingsAsync().
DefaultTimeout
();
66
var controlStream = await Http3Api.GetInboundControlStream().
DefaultTimeout
();
67
await controlStream.ExpectSettingsAsync().
DefaultTimeout
();
101
var controlStream = await Http3Api.GetInboundControlStream().
DefaultTimeout
();
102
await controlStream.ExpectSettingsAsync().
DefaultTimeout
();
133
var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_noopApplication, null).
DefaultTimeout
();
135
var controlStream = await Http3Api.GetInboundControlStream().
DefaultTimeout
();
136
await controlStream.ExpectSettingsAsync().
DefaultTimeout
();
174
var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_noopApplication, null).
DefaultTimeout
();
176
var controlStream = await Http3Api.GetInboundControlStream().
DefaultTimeout
();
177
await controlStream.ExpectSettingsAsync().
DefaultTimeout
();
223
var controlStream = await Http3Api.GetInboundControlStream().
DefaultTimeout
();
224
await controlStream.ExpectSettingsAsync().
DefaultTimeout
();
258
var controlStream = await Http3Api.GetInboundControlStream().
DefaultTimeout
();
259
await controlStream.ExpectSettingsAsync().
DefaultTimeout
();
287
var controlStream = await Http3Api.GetInboundControlStream().
DefaultTimeout
();
288
await controlStream.ExpectSettingsAsync().
DefaultTimeout
();
313
var controlStream = await Http3Api.GetInboundControlStream().
DefaultTimeout
();
314
await controlStream.ExpectSettingsAsync().
DefaultTimeout
();
Http3\WebTransport\WebTransportHandshakeTests.cs (3)
37
var session = await webTransportFeature.AcceptAsync(CancellationToken.None).
DefaultTimeout
(); // todo session is null here
62
await Http3Api.ServerReceivedSettingsReader.ReadAsync().
DefaultTimeout
();
128
await Http3Api.ServerReceivedSettingsReader.ReadAsync().
DefaultTimeout
();
Http3\WebTransport\WebTransportTestUtilities.cs (2)
35
var session = await webTransportFeature.AcceptAsync(CancellationToken.None).
DefaultTimeout
();
59
await inMemory.ServerReceivedSettingsReader.ReadAsync().
DefaultTimeout
();
src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (1)
112
while (await reader.WaitToReadAsync().
DefaultTimeout
())
Interop.FunctionalTests (10)
HttpClientHttp2InteropTests.cs (10)
273
var readResult = await reader.ReadAsync().
DefaultTimeout
();
277
readResult = await reader.ReadAsync().
DefaultTimeout
();
282
await context.Response.BodyWriter.WriteAsync(sequence.First).
DefaultTimeout
();
286
var finalResult = await reader.ReadAsync().
DefaultTimeout
();
330
var readResult = await reader.ReadAsync().
DefaultTimeout
();
334
readResult = await reader.ReadAsync().
DefaultTimeout
();
339
await context.Response.BodyWriter.WriteAsync(sequence.First).
DefaultTimeout
();
346
readResult = await reader.ReadAsync().
DefaultTimeout
();
350
readResult = await reader.ReadAsync().
DefaultTimeout
();
357
var finalResult = await reader.ReadAsync().
DefaultTimeout
();
Microsoft.AspNetCore.Components.Server.Tests (1)
Circuits\RemoteJSDataStreamTest.cs (1)
24
var remoteJSDataStream = await RemoteJSDataStream.CreateRemoteJSDataStreamAsync(_jsRuntime, jsStreamReference, totalLength: 100, signalRMaximumIncomingBytes: 10_000, jsInteropDefaultCallTimeout: TimeSpan.FromMinutes(1), cancellationToken: CancellationToken.None).
DefaultTimeout
();
Microsoft.AspNetCore.ConcurrencyLimiter.Tests (4)
PolicyTests\QueuePolicyTests.cs (4)
29
Assert.True(await s.TryEnterAsync().
DefaultTimeout
());
35
Assert.True(await waitingTask.
DefaultTimeout
());
67
Assert.True(await s1.TryEnterAsync().
DefaultTimeout
());
68
Assert.True(await s2.TryEnterAsync().
DefaultTimeout
());
Microsoft.AspNetCore.Http.Connections.Tests (15)
HttpConnectionDispatcherTests.cs (15)
1297
await connection.Transport.Output.WriteAsync(new byte[] { 1 }).
DefaultTimeout
();
1336
await connection.Transport.Output.WriteAsync(new byte[] { 1 }).
DefaultTimeout
();
1380
await connection.Transport.Output.WriteAsync(new byte[] { 1 }).
DefaultTimeout
();
2223
await c.Transport.Output.WriteAsync(Encoding.UTF8.GetBytes("Message1")).
DefaultTimeout
();
2226
await c.Transport.Output.WriteAsync(Encoding.UTF8.GetBytes("Message2")).
DefaultTimeout
();
2977
await connection.Application.Output.WriteAsync(new byte[] { 1 }).
DefaultTimeout
();
2982
Assert.Equal(3, await pollContext.Response.Body.ReadAsync(memory).
DefaultTimeout
());
2990
await connection.Application.Output.WriteAsync(new byte[] { 1 }).
DefaultTimeout
();
2994
Assert.Equal(3, await pollContext.Response.Body.ReadAsync(memory).
DefaultTimeout
());
3034
await connection.Application.Output.WriteAsync(new byte[] { 1 }).
DefaultTimeout
();
3039
Assert.Equal(3, await pollContext.Response.Body.ReadAsync(memory).
DefaultTimeout
());
3045
await connection.Application.Output.WriteAsync(new byte[] { 1 }).
DefaultTimeout
();
3049
Assert.Equal(3, await pollContext.Response.Body.ReadAsync(memory).
DefaultTimeout
());
3166
await connection.Application.Output.WriteAsync(new byte[] { 1 }).
DefaultTimeout
();
3171
Assert.Equal(1, await context.Response.Body.ReadAsync(memory).
DefaultTimeout
());
Microsoft.AspNetCore.Server.HttpSys.FunctionalTests (1)
RequestTests.cs (1)
564
await httpContext.Request.Body.ReadAsync(new byte[10]).
DefaultTimeout
();
Microsoft.AspNetCore.Server.Kestrel.Core.Tests (11)
ConcurrentPipeWriterTests.cs (10)
48
await flushTask.
DefaultTimeout
();
64
await flushTask.
DefaultTimeout
();
171
await flushTask0.
DefaultTimeout
();
172
await flushTask1.
DefaultTimeout
();
217
await flushTask0.
DefaultTimeout
();
242
await flushTask1.
DefaultTimeout
();
300
await flushTask0.
DefaultTimeout
();
381
Assert.True((await flushTask0.
DefaultTimeout
()).IsCanceled);
382
Assert.True((await flushTask1.
DefaultTimeout
()).IsCanceled);
393
await flushTask2.
DefaultTimeout
();
Http1\Http1ConnectionTests.cs (1)
830
await _http1Connection.WritePipeAsync(ReadOnlyMemory<byte>.Empty, default).
DefaultTimeout
();
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic.Tests (104)
QuicConnectionContextTests.cs (44)
33
var acceptTask = connectionListener.AcceptAndAddFeatureAsync().
DefaultTimeout
();
57
var acceptTask = connectionListener.AcceptAndAddFeatureAsync().
DefaultTimeout
();
83
var acceptTask = connectionListener.AcceptAndAddFeatureAsync().
DefaultTimeout
();
96
var serverStream = await acceptStreamTask.
DefaultTimeout
();
106
serverStream = await acceptStreamTask.
DefaultTimeout
();
109
var read = await serverStream.Transport.Input.ReadAtLeastAsync(TestData.Length).
DefaultTimeout
();
124
var acceptTask = connectionListener.AcceptAndAddFeatureAsync().
DefaultTimeout
();
156
await using var serverConnection = await connectionListener.AcceptAndAddFeatureAsync().
DefaultTimeout
();
164
await using var serverStream = await acceptTask.
DefaultTimeout
();
174
var read = await serverStream.Transport.Input.ReadAtLeastAsync(TestData.Length).
DefaultTimeout
();
182
read = await serverStream.Transport.Input.ReadAsync().
DefaultTimeout
();
198
var serverConnection = await connectionListener.AcceptAndAddFeatureAsync().
DefaultTimeout
();
206
await using var serverStream = await acceptTask.
DefaultTimeout
();
217
var read = await serverStream.Transport.Input.ReadAtLeastAsync(TestData.Length).
DefaultTimeout
();
230
read = await serverStream.Transport.Input.ReadAsync().
DefaultTimeout
();
248
var serverConnection = await connectionListener.AcceptAndAddFeatureAsync().
DefaultTimeout
();
254
await serverStream.Transport.Output.WriteAsync(TestData).
DefaultTimeout
();
256
await using var clientStream = await acceptTask.
DefaultTimeout
();
265
while ((readCount = await clientStream.ReadAsync(buffer).
DefaultTimeout
()) != -1)
279
readCount = await clientStream.ReadAsync(buffer).
DefaultTimeout
();
293
var serverConnection = await connectionListener.AcceptAndAddFeatureAsync().
DefaultTimeout
();
319
await using var serverConnection = await connectionListener.AcceptAndAddFeatureAsync().
DefaultTimeout
();
330
var serverStream = await serverConnection.AcceptAsync().
DefaultTimeout
();
331
var readResult = await serverStream.Transport.Input.ReadAtLeastAsync(TestData.Length).
DefaultTimeout
();
362
await using var serverConnection = await connectionListener.AcceptAndAddFeatureAsync().
DefaultTimeout
();
373
var serverStream = await serverConnection.AcceptAsync().
DefaultTimeout
();
374
var readResult = await serverStream.Transport.Input.ReadAtLeastAsync(TestData.Length).
DefaultTimeout
();
407
await using var serverConnection = await connectionListener.AcceptAndAddFeatureAsync().
DefaultTimeout
();
419
var serverStream = await serverConnection.AcceptAsync().
DefaultTimeout
();
420
var readResult = await serverStream.Transport.Input.ReadAtLeastAsync(TestData.Length).
DefaultTimeout
();
456
await using var serverConnection = await connectionListener.AcceptAndAddFeatureAsync().
DefaultTimeout
();
468
var serverStream = await serverConnection.AcceptAsync().
DefaultTimeout
();
469
var readResult = await serverStream.Transport.Input.ReadAtLeastAsync(TestData.Length).
DefaultTimeout
();
514
await using var serverConnection = await connectionListener.AcceptAndAddFeatureAsync().
DefaultTimeout
();
568
await using var serverConnection = await connectionListener.AcceptAndAddFeatureAsync().
DefaultTimeout
();
610
var serverStream = await requestState.ServerConnection.AcceptAsync().
DefaultTimeout
();
612
var readResult = await serverStream.Transport.Input.ReadAtLeastAsync(TestData.Length).
DefaultTimeout
();
673
await using var serverConnection = await connectionListener.AcceptAndAddFeatureAsync().
DefaultTimeout
();
681
var serverStream1 = await serverConnection.AcceptAsync().
DefaultTimeout
();
684
var readResult1 = await serverStream1.Transport.Input.ReadAtLeastAsync(TestData.Length).
DefaultTimeout
();
709
var serverStream2 = await serverConnection.AcceptAsync().
DefaultTimeout
();
712
var readResult2 = await serverStream2.Transport.Input.ReadAtLeastAsync(TestData.Length).
DefaultTimeout
();
752
await using var serverConnection = await connectionListener.AcceptAndAddFeatureAsync().
DefaultTimeout
();
758
var serverStream = await serverConnection.AcceptAsync().
DefaultTimeout
();
QuicConnectionListenerTests.cs (15)
38
Assert.Null(await connectionListener.AcceptAndAddFeatureAsync().
DefaultTimeout
());
49
var acceptTask = connectionListener.AcceptAndAddFeatureAsync().
DefaultTimeout
();
73
var acceptTask1 = connectionListener.AcceptAndAddFeatureAsync().
DefaultTimeout
();
85
var acceptTask2 = connectionListener.AcceptAndAddFeatureAsync().
DefaultTimeout
();
124
var serverConnection = await connectionListener.AcceptAndAddFeatureAsync().
DefaultTimeout
();
126
var serverStreamTask = serverConnection.AcceptAsync().
DefaultTimeout
();
180
var acceptTask = connectionListener.AcceptAndAddFeatureAsync().
DefaultTimeout
();
263
await using var clientConnection = await QuicConnection.ConnectAsync(options).
DefaultTimeout
();
264
await using var serverConnection = await acceptTask.
DefaultTimeout
();
321
await using var clientConnection = await QuicConnection.ConnectAsync(options).
DefaultTimeout
();
322
await using var serverConnection = await acceptTask.
DefaultTimeout
();
363
await using var serverConnection = await acceptTask.
DefaultTimeout
();
364
await using var clientConnection = await clientConnectionTask.
DefaultTimeout
();
448
var acceptTask = connectionListener.AcceptAndAddFeatureAsync().
DefaultTimeout
();
452
await using var clientConnection = await QuicConnection.ConnectAsync(options).
DefaultTimeout
();
QuicStreamContextTests.cs (43)
40
await using var serverConnection = await connectionListener.AcceptAndAddFeatureAsync().
DefaultTimeout
();
64
await using var serverConnection = await connectionListener.AcceptAndAddFeatureAsync().
DefaultTimeout
();
69
var serverStream = await serverConnection.AcceptAsync().
DefaultTimeout
();
70
var readResult = await serverStream.Transport.Input.ReadAtLeastAsync(TestData.Length).
DefaultTimeout
();
112
await using var serverConnection = await connectionListener.AcceptAndAddFeatureAsync().
DefaultTimeout
();
122
var serverStream = await serverConnection.AcceptAsync().
DefaultTimeout
();
123
var readResult = await serverStream.Transport.Input.ReadAtLeastAsync(TestData.Length).
DefaultTimeout
();
128
await serverStream.Transport.Output.WriteAsync(new byte[1024 * 1024 * 32]).
DefaultTimeout
();
180
await using var serverConnection = await connectionListener.AcceptAndAddFeatureAsync().
DefaultTimeout
();
186
var serverStream = await serverConnection.AcceptAsync().
DefaultTimeout
();
189
var readResult = await serverStream.Transport.Input.ReadAtLeastAsync(TestData.Length).
DefaultTimeout
();
193
readResult = await serverStream.Transport.Input.ReadAsync().
DefaultTimeout
();
200
await serverStream.Transport.Output.WriteAsync(testData).
DefaultTimeout
();
238
await using var serverConnection = await connectionListener.AcceptAndAddFeatureAsync().
DefaultTimeout
();
260
await using var serverConnection = await connectionListener.AcceptAndAddFeatureAsync().
DefaultTimeout
();
266
await using var serverStream = await serverConnection.AcceptAsync().
DefaultTimeout
();
267
var readResult = await serverStream.Transport.Input.ReadAtLeastAsync(TestData.Length).
DefaultTimeout
();
304
await using var serverConnection = await connectionListener.AcceptAndAddFeatureAsync().
DefaultTimeout
();
310
await using var serverStream = await serverConnection.AcceptAsync().
DefaultTimeout
();
311
var readResult = await serverStream.Transport.Input.ReadAtLeastAsync(TestData.Length).
DefaultTimeout
();
315
readResult = await serverStream.Transport.Input.ReadAsync().
DefaultTimeout
();
338
await using var serverConnection = await connectionListener.AcceptAndAddFeatureAsync().
DefaultTimeout
();
344
await using var serverStream = await serverConnection.AcceptAsync().
DefaultTimeout
();
345
var readResult = await serverStream.Transport.Input.ReadAtLeastAsync(TestData.Length).
DefaultTimeout
();
377
await using var serverConnection = await connectionListener.AcceptAndAddFeatureAsync().
DefaultTimeout
();
383
await using var serverStream = await serverConnection.AcceptAsync().
DefaultTimeout
();
384
var readResult = await serverStream.Transport.Input.ReadAtLeastAsync(TestData.Length).
DefaultTimeout
();
392
var completeReadResult = await readResultTask.
DefaultTimeout
();
408
await using var serverConnection = await connectionListener.AcceptAndAddFeatureAsync().
DefaultTimeout
();
413
var serverStream = await serverConnection.ConnectAsync(features).
DefaultTimeout
();
414
await serverStream.Transport.Output.WriteAsync(TestData).
DefaultTimeout
();
424
var readCount = await clientStream.ReadAsync(new byte[1024]).
DefaultTimeout
();
449
await using var serverConnection = await connectionListener.AcceptAndAddFeatureAsync().
DefaultTimeout
();
454
var serverStream = await serverConnection.ConnectAsync(features).
DefaultTimeout
();
455
await serverStream.Transport.Output.WriteAsync(TestData).
DefaultTimeout
();
493
await using var serverConnection = await connectionListener.AcceptAndAddFeatureAsync().
DefaultTimeout
();
499
await using var serverStream = await serverConnection.AcceptAsync().
DefaultTimeout
();
501
var readResult = await serverStream.Transport.Input.ReadAtLeastAsync(TestData.Length).
DefaultTimeout
();
513
await serverStream.Transport.Output.WriteAsync(TestData).
DefaultTimeout
();
543
await using var serverConnection = await connectionListener.AcceptAndAddFeatureAsync().
DefaultTimeout
();
549
var serverStream = await serverConnection.AcceptAsync().
DefaultTimeout
();
570
await using var serverConnection = await connectionListener.AcceptAndAddFeatureAsync().
DefaultTimeout
();
576
var serverStream = await serverConnection.AcceptAsync().
DefaultTimeout
();
QuicTestHelpers.cs (2)
152
var serverStream = await serverConnection.AcceptAsync().
DefaultTimeout
();
155
var readResult = await serverStream.Transport.Input.ReadAtLeastAsync(TestData.Length).
DefaultTimeout
();
Microsoft.AspNetCore.SignalR.Client.FunctionalTests (4)
HubConnectionTests.Tracing.cs (2)
83
clientActivity1 = await clientChannel.Reader.ReadAsync().
DefaultTimeout
();
105
clientActivity2 = await clientChannel.Reader.ReadAsync().
DefaultTimeout
();
HubProtocolVersionTests.cs (2)
134
var connectionContext = await proxyConnectionFactory.ConnectTask.
DefaultTimeout
();
144
await connectionContext.Transport.Output.FlushAsync().
DefaultTimeout
();
Microsoft.AspNetCore.SignalR.Client.Tests (10)
HttpConnectionTests.ConnectionLifecycle.cs (1)
315
await connection.Transport.Output.WriteAsync(new byte[] { 0x42 }).
DefaultTimeout
();
HttpConnectionTests.Transport.cs (3)
246
await connection.Transport.Output.WriteAsync(data).
DefaultTimeout
();
262
() => connection.Transport.Output.WriteAsync(new byte[0]).
DefaultTimeout
());
278
() => connection.Transport.Output.WriteAsync(new byte[0]).
DefaultTimeout
());
HubConnectionTests.ConnectionLifecycle.cs (1)
626
await innerConnection.Application.Output.WriteAsync(Encoding.UTF8.GetBytes(new[] { '{' })).
DefaultTimeout
();
HubConnectionTests.cs (4)
272
await Assert.ThrowsAsync<TaskCanceledException>(() => result.GetAsyncEnumerator().MoveNextAsync().
DefaultTimeout
());
301
await task.
DefaultTimeout
();
303
while (await e.MoveNextAsync().
DefaultTimeout
())
333
await task.
DefaultTimeout
();
HubConnectionTests.Reconnect.cs (1)
920
await currentTestConnection.Application.Output.WriteAsync(output.ToArray()).
DefaultTimeout
();
Microsoft.AspNetCore.SignalR.Tests (31)
EndToEndTests.cs (3)
193
await connection.Transport.Output.WriteAsync(message).
DefaultTimeout
();
279
await connection.Transport.Output.WriteAsync(bytes).
DefaultTimeout
();
336
await connection.Transport.Output.WriteAsync(bytes).
DefaultTimeout
();
HubConnectionHandlerTests.Activity.cs (17)
54
var connectActivity = await serverChannel.Reader.ReadAsync().
DefaultTimeout
();
63
var invocation1Activity = await serverChannel.Reader.ReadAsync().
DefaultTimeout
();
69
var invocation2Activity = await serverChannel.Reader.ReadAsync().
DefaultTimeout
();
75
var invocation3Activity = await serverChannel.Reader.ReadAsync().
DefaultTimeout
();
78
var userCodeActivity = await serverChannel.Reader.ReadAsync().
DefaultTimeout
();
87
var disconnectActivity = await serverChannel.Reader.ReadAsync().
DefaultTimeout
();
129
var connectActivity = await serverChannel.Reader.ReadAsync().
DefaultTimeout
();
145
var invocationActivity = await serverChannel.Reader.ReadAsync().
DefaultTimeout
();
159
var disconnectActivity = await serverChannel.Reader.ReadAsync().
DefaultTimeout
();
200
var connectActivity = await serverChannel.Reader.ReadAsync().
DefaultTimeout
();
205
var invocation1Activity = await serverChannel.Reader.ReadAsync().
DefaultTimeout
();
210
var invocation2Activity = await serverChannel.Reader.ReadAsync().
DefaultTimeout
();
218
var disconnectedActivity = await serverChannel.Reader.ReadAsync().
DefaultTimeout
();
259
var connectActivity = await serverChannel.Reader.ReadAsync().
DefaultTimeout
();
271
var invocationActivity = await serverChannel.Reader.ReadAsync().
DefaultTimeout
();
285
var disconnectActivity = await serverChannel.Reader.ReadAsync().
DefaultTimeout
();
330
var activity = await serverChannel.Reader.ReadAsync().
DefaultTimeout
();
HubConnectionHandlerTests.cs (2)
669
await client.Connection.Application.Output.WriteAsync(payload).
DefaultTimeout
();
3566
await client.Connection.Application.Output.WriteAsync(Encoding.UTF8.GetBytes(new[] { '{' })).
DefaultTimeout
();
Internal\MessageBufferTests.cs (9)
29
await messageBuffer.WriteAsync(PingMessage.Instance, default).
DefaultTimeout
();
35
var res = await pipes.Application.Input.ReadAsync().
DefaultTimeout
();
72
await writeTask.
DefaultTimeout
();
74
res = await pipes.Application.Input.ReadAsync().
DefaultTimeout
();
308
await messageBuffer.WriteAsync(new StreamItemMessage("1", null), default).
DefaultTimeout
();
366
await writeTask.
DefaultTimeout
();
368
res = await pipes.Application.Input.ReadAsync().
DefaultTimeout
();
467
await messageBuffer.WriteAsync(new SerializedHubMessage(new InvocationMessage("t", new object[] { new byte[100] })), default).
DefaultTimeout
();
510
var writeTask = messageBuffer.WriteAsync(new SerializedHubMessage(new InvocationMessage("t", new object[] { new byte[100] })), default).
DefaultTimeout
();
Sockets.FunctionalTests (2)
src\Servers\Kestrel\test\FunctionalTests\UnixDomainSocketsTests.cs (2)
108
var bytesReceived = await socket.ReceiveAsync(buffer.AsMemory(read, buffer.Length - read), SocketFlags.None).
DefaultTimeout
();
176
var bytesReceived = await socket.ReceiveAsync(readBuffer.AsMemory(read), SocketFlags.None).
DefaultTimeout
();