| /dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Net.Sockets/tests/FunctionalTests/ |
| H A D | SocketTestHelper.cs | 19 public abstract Task<int> ReceiveAsync(Socket s, ArraySegment<byte> buffer); in ReceiveAsync() method in System.Net.Sockets.Tests.SocketHelperBase
44 public override Task<int> ReceiveAsync(Socket s, ArraySegment<byte> buffer) => in ReceiveAsync() method in System.Net.Sockets.Tests.SocketHelperArraySync
90 public override Task<int> ReceiveAsync(Socket s, ArraySegment<byte> buffer) => in ReceiveAsync() method in System.Net.Sockets.Tests.SocketHelperApm
138 public override Task<int> ReceiveAsync(Socket s, ArraySegment<byte> buffer) => in ReceiveAsync() method in System.Net.Sockets.Tests.SocketHelperTask
139 s.ReceiveAsync(buffer, SocketFlags.None); in ReceiveAsync()
141 s.ReceiveAsync(bufferList, SocketFlags.None); in ReceiveAsync()
171 public override Task<int> ReceiveAsync(Socket s, ArraySegment<byte> buffer) => in ReceiveAsync() method in System.Net.Sockets.Tests.SocketHelperEap
175 return s.ReceiveAsync(e); in ReceiveAsync()
181 return s.ReceiveAsync(e); in ReceiveAsync()
252 …public Task<int> ReceiveAsync(Socket s, ArraySegment<byte> buffer) => _socketHelper.ReceiveAsync(s… in ReceiveAsync() method in System.Net.Sockets.Tests.SocketTestHelperBase
[all …]
|
| H A D | SocketTestHelper.netcoreapp.cs | 13 public override Task<int> ReceiveAsync(Socket s, ArraySegment<byte> buffer) => in ReceiveAsync() method in System.Net.Sockets.Tests.SocketHelperSpanSync
31 public override Task<int> ReceiveAsync(Socket s, ArraySegment<byte> buffer) => in ReceiveAsync() method in System.Net.Sockets.Tests.SocketHelperMemoryArrayTask
32 s.ReceiveAsync((Memory<byte>)buffer, SocketFlags.None).AsTask(); in ReceiveAsync()
40 public override async Task<int> ReceiveAsync(Socket s, ArraySegment<byte> buffer) in ReceiveAsync() method in System.Net.Sockets.Tests.SocketHelperMemoryNativeTask
44 … int bytesReceived = await s.ReceiveAsync(m.Memory, SocketFlags.None).ConfigureAwait(false); in ReceiveAsync()
|
| H A D | SendReceive.cs | 31 … await Assert.ThrowsAsync(expectedExceptionType, () => ReceiveAsync(s, invalidBuffer)); in InvalidArguments_Throws()
161 int received = await ReceiveAsync(remote, recvBuffers); in SendRecv_Stream_TCP()
271 … int received = await ReceiveAsync(server, new ArraySegment<byte>(recvBuffer)); in SendRecv_Stream_TCP_LargeMultiBufferSends()
313 received = await ReceiveAsync(remote, seg1); in SendRecv_Stream_TCP_AlternateBufferAndBufferList()
463 Task<int> receive1 = ReceiveAsync(client, buffer1); in SendRecv_Stream_TCP_MultipleConcurrentReceives()
464 Task<int> receive2 = ReceiveAsync(client, buffer2); in SendRecv_Stream_TCP_MultipleConcurrentReceives()
465 Task<int> receive3 = ReceiveAsync(client, buffer3); in SendRecv_Stream_TCP_MultipleConcurrentReceives()
740 Task<int> receive = ReceiveAsync(client, new ArraySegment<byte>(new byte[1])); in SendRecv_BlockingNonBlocking_LingerTimeout_Success()
776 int received = await ReceiveAsync(server, receiveBuffer); in SendRecv_NoBuffering_Success()
805 Task receiveTask = ReceiveAsync(client, new ArraySegment<byte>(new byte[1])); in SendRecv_DisposeDuringPendingReceive_ThrowsSocketException()
[all …]
|
| H A D | SocketAsyncEventArgsTest.cs | 90 Assert.True(client.ReceiveAsync(receiveSaea)); in Dispose_WhileInUse_DisposeDelayed()
91 …Assert.Throws<InvalidOperationException>(() => client.ReceiveAsync(receiveSaea)); // already in pr… in Dispose_WhileInUse_DisposeDelayed()
98 Assert.Throws<ObjectDisposedException>(() => client.ReceiveAsync(receiveSaea)); in Dispose_WhileInUse_DisposeDelayed()
140 Assert.True(client.ReceiveAsync(receiveSaea)); in ExecutionContext_FlowsIfNotSuppressed()
304 Assert.True(client.ReceiveAsync(receiveSaea)); in Completed_RegisterThenInvoked_UnregisterThenNotInvoked()
313 Assert.True(client.ReceiveAsync(receiveSaea)); in Completed_RegisterThenInvoked_UnregisterThenNotInvoked()
407 if (client.ReceiveAsync(args)) in ReuseSocketAsyncEventArgs_SameInstance_MultipleSockets()
463 if (client.ReceiveAsync(recvArgs)) in ReuseSocketAsyncEventArgs_MutateBufferList()
|
| /dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Net.Sockets/src/System/Net/Sockets/ |
| H A D | SocketTaskExtensions.cs | 27 …public static Task<int> ReceiveAsync(this Socket socket, ArraySegment<byte> buffer, SocketFlags so… in ReceiveAsync() method in System.Net.Sockets.SocketTaskExtensions
28 socket.ReceiveAsync(buffer, socketFlags, fromNetworkStream: false); in ReceiveAsync()
29 …public static ValueTask<int> ReceiveAsync(this Socket socket, Memory<byte> buffer, SocketFlags soc… in ReceiveAsync() method in System.Net.Sockets.SocketTaskExtensions
30 …socket.ReceiveAsync(buffer, socketFlags, fromNetworkStream: false, cancellationToken: cancellation… in ReceiveAsync()
31 …public static Task<int> ReceiveAsync(this Socket socket, IList<ArraySegment<byte>> buffers, Socket… in ReceiveAsync() method in System.Net.Sockets.SocketTaskExtensions
32 socket.ReceiveAsync(buffers, socketFlags); in ReceiveAsync()
|
| /dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Net.WebSockets.Client/tests/ |
| H A D | SendReceiveTest.cs | 22 ws.ReceiveAsync(arraySegment, cancellationToken); in ReceiveAsync()
61 … WebSocketReceiveResult recvResult = await ReceiveAsync(cws, receiveSegment, ctsDefault.Token); in SendReceive_PartialMessageDueToSmallReceiveBuffer_Success()
66 recvResult = await ReceiveAsync(cws, receiveSegment, ctsDefault.Token); in SendReceive_PartialMessageDueToSmallReceiveBuffer_Success()
98 WebSocketReceiveResult recvResult = await ReceiveAsync( in SendReceive_PartialMessageBeforeCompleteMessageArrives_Success()
226 tasks[i] = ReceiveAsync(cws, recvSegment, cts.Token); in ReceiveAsync_MultipleOutstandingReceiveOperations_Throws()
294 WebSocketReceiveResult recvRet = await ReceiveAsync(cws, receiveSegment, cts.Token); in SendAsync_SendZeroLengthPayloadAsEndOfMessage_Success()
330 WebSocketReceiveResult recvResult = await ReceiveAsync( in SendReceive_VaryingLengthBuffers_Success()
411 Task pendingReceiveAsync = ReceiveAsync(clientSocket, recvSegment, cts.Token); in SendReceive_ConnectionClosedPrematurely_ReceiveAsyncFailsAndWebSocketStateUpdated()
426 …await Assert.ThrowsAsync<WebSocketException>(() => ReceiveAsync(clientSocket, recvSegment, cts.Tok… in SendReceive_ConnectionClosedPrematurely_ReceiveAsyncFailsAndWebSocketStateUpdated()
440 …await Assert.ThrowsAsync<WebSocketException>(() => ReceiveAsync(clientSocket, recvSegment, cts.Tok… in SendReceive_ConnectionClosedPrematurely_ReceiveAsyncFailsAndWebSocketStateUpdated()
[all …]
|
| H A D | CancelTest.cs | 72 await cws.ReceiveAsync(segment, cts.Token); in ReceiveAsync_Cancel_Success()
132 Task receive = cws.ReceiveAsync(segment, cts.Token); in ReceiveAsync_CancelThenReceive_ThrowsOperationCanceledException()
147 Task receive = cws.ReceiveAsync(segment, cts.Token); in ReceiveAsync_ReceiveThenCancel_ThrowsOperationCanceledException()
163 Task receive = cws.ReceiveAsync(segment, cts.Token); in ReceiveAsync_AfterCancellationDoReceiveAsync_ThrowsWebSocketException()
168 cws.ReceiveAsync(segment, CancellationToken.None)); in ReceiveAsync_AfterCancellationDoReceiveAsync_ThrowsWebSocketException()
|
| H A D | SendReceiveTest.netcoreapp.cs | 16 …protected override async Task<WebSocketReceiveResult> ReceiveAsync(WebSocket ws, ArraySegment<byte… in ReceiveAsync() method in System.Net.WebSockets.Client.Tests.MemorySendReceiveTest
18 ValueWebSocketReceiveResult r = await ws.ReceiveAsync( in ReceiveAsync()
|
| /dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Data.SqlClient/src/System/Data/SqlClient/SNI/ |
| H A D | SNIMarsConnection.cs | 67 if (ReceiveAsync(ref packet) == TdsEnums.SNI_SUCCESS_IO_PENDING) in StartReceive()
107 public uint ReceiveAsync(ref SNIPacket packet) in ReceiveAsync() method in System.Data.SqlClient.SNI.SNIMarsConnection
111 return _lowerHandle.ReceiveAsync(ref packet); in ReceiveAsync()
187 sniErrorCode = ReceiveAsync(ref packet); in HandleReceiveComplete()
226 sniErrorCode = ReceiveAsync(ref packet); in HandleReceiveComplete()
281 sniErrorCode = ReceiveAsync(ref packet); in HandleReceiveComplete()
|
| /dports/lang/mono/mono-5.10.1.57/mcs/class/System.Threading.Tasks.Dataflow/Test/System.Threading.Tasks.Dataflow/ |
| H A D | InvalidArgumentsTest.cs | 384 () => DataflowBlock.ReceiveAsync ((ISourceBlock<int>)null)); in ReceiveAsyncTest()
387 () => DataflowBlock.ReceiveAsync ((ISourceBlock<int>)null, in ReceiveAsyncTest()
391 () => DataflowBlock.ReceiveAsync ((ISourceBlock<int>)null, in ReceiveAsyncTest()
394 DataflowBlock.ReceiveAsync (source, TimeSpan.FromMilliseconds (-1)); in ReceiveAsyncTest()
396 () => DataflowBlock.ReceiveAsync (source, TimeSpan.FromMilliseconds (-2))); in ReceiveAsyncTest()
400 () => DataflowBlock.ReceiveAsync (source, in ReceiveAsyncTest()
404 () => DataflowBlock.ReceiveAsync ((ISourceBlock<int>)null, in ReceiveAsyncTest()
407 DataflowBlock.ReceiveAsync (source, TimeSpan.FromMilliseconds (-1), in ReceiveAsyncTest()
410 () => DataflowBlock.ReceiveAsync (source, TimeSpan.FromMilliseconds (-2), in ReceiveAsyncTest()
413 DataflowBlock.ReceiveAsync (source, TimeSpan.FromMilliseconds (int.MaxValue), in ReceiveAsyncTest()
[all …]
|
| /dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Threading.Tasks.Dataflow/tests/Dataflow/ |
| H A D | DataflowBlockExtensionTests.cs | 394 Task<int> first = targets[0].ReceiveAsync(); in TestAsObservableAndAsObserver_BroadcastBackPressure()
396 Task<int> third = targets[2].ReceiveAsync(); in TestAsObservableAndAsObserver_BroadcastBackPressure()
404 await Task.WhenAll(targets[0].ReceiveAsync(), targets[2].ReceiveAsync()); in TestAsObservableAndAsObserver_BroadcastBackPressure()
412 …await Task.WhenAll(targets[1].ReceiveAsync(), targets[1].ReceiveAsync()); // clear two items from … in TestAsObservableAndAsObserver_BroadcastBackPressure()
993 var t1 = buffer.ReceiveAsync(); in TestReceive_NotYetAvailable()
1048 var t = bb.ReceiveAsync(cts.Token); in TestReceive_Cancellation()
1062 var t = bb.ReceiveAsync(cts.Token); in TestReceive_Cancellation()
1098 var t = bb.ReceiveAsync(); in TestReceive_CanceledSource()
1130 Task t = bb.ReceiveAsync(); in TestReceiveAsync_LongChain()
1133 t = t.ContinueWith(_ => bb.ReceiveAsync(), in TestReceiveAsync_LongChain()
[all …]
|
| H A D | BroadcastBlockTests.cs | 73 …Assert.Equal(expected: 42, actual: await bb.ReceiveAsync()); // this should always pass, but due t… in TestReceiveThenPost()
76 Task<int> t = bb.ReceiveAsync(); in TestReceiveThenPost()
98 Assert.Equal(expected: i + 1, actual: await target.ReceiveAsync()); in TestBroadcasting()
108 Assert.Equal(expected: 42, actual: await bb.ReceiveAsync()); in TestRepeatedReceives()
158 Assert.Equal(expected: -data, actual: await bb.ReceiveAsync()); in TestCloning()
160 Assert.Equal(expected: -data, actual: await bb.ReceiveAsync()); in TestCloning()
188 Assert.Equal(expected: data, actual: await bb.ReceiveAsync()); in TestCloning()
190 Assert.Equal(expected: data, actual: await bb.ReceiveAsync()); in TestCloning()
|
| H A D | TransformBlockTests.cs | 147 Assert.Equal(expected: i * 2, actual: await tb.ReceiveAsync()); in TestReceives()
210 Assert.Equal(expected: i, actual: await tb.ReceiveAsync()); in TestProducerConsumer()
444 Assert.Equal(expected: 0, actual: await tb.ReceiveAsync()); in TestFaultingAndCancellation()
445 Assert.Equal(expected: 1, actual: await tb.ReceiveAsync()); in TestFaultingAndCancellation()
477 Assert.Equal(expected: i, actual: await t.ReceiveAsync()); in TestCancellationExceptionsIgnored()
502 Assert.Equal(expected: i, actual: await tb.ReceiveAsync()); in TestNullTasksIgnored()
573 Assert.Equal(expected: i, actual: await tb.ReceiveAsync()); in TestOrdering_Sync_OrderedEnabled()
606 Assert.Equal(expected: i, actual: await tb.ReceiveAsync()); in TestOrdering_Async_OrderedEnabled()
631 Assert.Equal(expected: i, actual: await tb.ReceiveAsync()); in TestOrdering_Async_OrderedDisabled()
654 Assert.Equal(1, await tb.ReceiveAsync()); in TestOrdering_Sync_OrderedDisabled()
[all …]
|
| H A D | TransformManyBlockTests.cs | 277 Assert.Equal(expected: i, actual: await t.ReceiveAsync()); in TestMultipleYields()
488 Assert.Equal(expected: 0, actual: await tb.ReceiveAsync()); in TestFaultingAndCancellation()
489 Assert.Equal(expected: 1, actual: await tb.ReceiveAsync()); in TestFaultingAndCancellation()
528 Assert.Equal(expected: i, actual: await t.ReceiveAsync()); in TestCancellationExceptionsIgnored()
554 Assert.Equal(expected: i, actual: await tb.ReceiveAsync()); in TestNullTasksIgnored()
589 await tb.ReceiveAsync(); in TestYieldingNoResults()
682 Assert.Equal(expected: i, actual: await tb.ReceiveAsync()); in TestOrdering_Sync_OrderedEnabled()
715 Assert.Equal(expected: i, actual: await tb.ReceiveAsync()); in TestOrdering_Async_OrderedEnabled()
744 Assert.Equal(expected: i, actual: await tb.ReceiveAsync()); in TestOrdering_Async_OrderedDisabled()
771 Assert.Equal(1, await tb.ReceiveAsync()); in TestOrdering_Sync_OrderedDisabled()
[all …]
|
| H A D | BatchBlockTests.cs | 209 item = await bb.ReceiveAsync(); in TestBoundedReceives()
217 item = await bb.ReceiveAsync(); in TestBoundedReceives()
246 int[] items = await bb.ReceiveAsync(); in TestProducerConsumer()
295 int[] result = await batch.ReceiveAsync(); in TestNonGreedy()
321 int[] result = await batch.ReceiveAsync(); in TestGreedyFromPosts()
352 int sum = (await batch.ReceiveAsync()).Sum(); in TestMultipleNonGreedyFromSources()
480 int[] results = await batch.ReceiveAsync(); in TestNonGreedyLostMessages()
519 Assert.Equal(expected: 0, actual: (await bb.ReceiveAsync())[0]); in TestFaultingAndCancellation()
547 int[] items = await b.ReceiveAsync(); in TestCompletionWithBufferedItems()
594 int[] result = await batch.ReceiveAsync(); in TestMaxNumberOfGroups()
[all …]
|
| H A D | BufferBlockTests.cs | 199 Assert.Equal(expected: i - 1, actual: await bb.ReceiveAsync()); in TestBoundedReceives()
205 Assert.Equal(expected: sends, actual: await bb.ReceiveAsync()); in TestBoundedReceives()
247 Assert.Equal(expected: i, actual: await bb.ReceiveAsync()); in TestProducerConsumer()
391 Assert.Equal(expected: i, actual: await network.ReceiveAsync()); in TestChainedSendReceive()
415 Assert.Equal(expected: i, actual: await network.ReceiveAsync()); in TestSendAllThenReceive()
457 Assert.Equal(expected: 0, actual: await bb.ReceiveAsync()); in TestFaultingAndCancellation()
458 Assert.Equal(expected: 1, actual: await bb.ReceiveAsync()); in TestFaultingAndCancellation()
544 Assert.Equal(expected: 1, actual: await target1.ReceiveAsync()); in TestMultiplePostponesFromSameSource()
545 Assert.Equal(expected: 2, actual: await target1.ReceiveAsync()); in TestMultiplePostponesFromSameSource()
|
| /dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Net.WebSockets.Client/src/System/Net/WebSockets/ |
| H A D | WebSocketHandle.Windows.cs | 100 public Task<WebSocketReceiveResult> ReceiveAsync( in ReceiveAsync() method
105 return _webSocket.ReceiveAsync(buffer, cancellationToken); in ReceiveAsync()
108 …public ValueTask<ValueWebSocketReceiveResult> ReceiveAsync(Memory<byte> buffer, CancellationToken … in ReceiveAsync() method
109 _webSocket.ReceiveAsync(buffer, cancellationToken); in ReceiveAsync()
|
| H A D | ClientWebSocket.cs | 174 public override Task<WebSocketReceiveResult> ReceiveAsync(ArraySegment<byte> buffer, in ReceiveAsync() method in System.Net.WebSockets.ClientWebSocket
178 return _innerWebSocket.ReceiveAsync(buffer, cancellationToken); in ReceiveAsync()
181 …public override ValueTask<ValueWebSocketReceiveResult> ReceiveAsync(Memory<byte> buffer, Cancellat… in ReceiveAsync() method in System.Net.WebSockets.ClientWebSocket
184 return _innerWebSocket.ReceiveAsync(buffer, cancellationToken); in ReceiveAsync()
|
| /dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Net.Sockets/tests/Performance/ |
| H A D | Perf.Socket.SendReceive.cs | 30 await server.ReceiveAsync(serverBuffer, SocketFlags.None); in SendAsyncThenReceiveAsync_Task()
51 Task r = server.ReceiveAsync(serverBuffer, SocketFlags.None); in ReceiveAsyncThenSendAsync_Task()
75 Task r = server.ReceiveAsync(serverBuffer, SocketFlags.None); in ReceiveAsyncThenSendAsync_Task_Parallel()
106 if (server.ReceiveAsync(serverSaea)) in SendAsyncThenReceiveAsync_SocketAsyncEventArgs()
134 bool pendingServer = server.ReceiveAsync(serverSaea); in ReceiveAsyncThenSendAsync_SocketAsyncEventArgs()
|
| /dports/irc/smuxi/smuxi-1.1/lib/ServiceStack/src/ServiceStack.Common/Messaging/Rcon/ |
| H A D | Client.cs | 97 if (!_sock.ReceiveAsync(readEventArgs)) in Connect()
137 if (!readingSock.ReceiveAsync(e)) in ProcessReceive()
144 if (!readingSock.ReceiveAsync(e)) in ProcessReceive()
166 if (!readingSock.ReceiveAsync(e)) in ProcessReceive()
173 if (!readingSock.ReceiveAsync(e)) in ProcessReceive()
|
| H A D | Server.cs | 166 if (!newSocket.ReceiveAsync(readEventArgs)) in ProcessAccept()
199 if (!readingSock.ReceiveAsync(e)) in ProcessReceive()
206 if (!readingSock.ReceiveAsync(e)) in ProcessReceive()
231 if (!readingSock.ReceiveAsync(e)) in ProcessReceive()
238 if (!readingSock.ReceiveAsync(e)) in ProcessReceive()
|
| /dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Net.HttpListener/tests/ |
| H A D | HttpListenerWebSocketTests.cs | 121 …sAsync<ArgumentNullException>("buffer.Array", () => context.WebSocket.ReceiveAsync(new ArraySegmen… in ReceiveAsync_NoInnerBuffer_ThrowsArgumentNullException()
131 …await Assert.ThrowsAsync<ObjectDisposedException>(() => context.WebSocket.ReceiveAsync(new ArraySe… in ReceiveAsync_Disposed_ThrowsObjectDisposedException()
159 …Task<WebSocketReceiveResult> clientReceiveTask = Client.ReceiveAsync(new ArraySegment<byte>(receiv… in CloseOutputAsync_HandshakeStartedFromClient_Success()
181 …Task<WebSocketReceiveResult> serverReceiveTask = context.WebSocket.ReceiveAsync(new ArraySegment<b… in CloseOutputAsync_HandshakeStartedFromClient_Success()
197 …await Assert.ThrowsAsync<WebSocketException>(() => context.WebSocket.ReceiveAsync(new ArraySegment… in CloseOutputAsync_HandshakeStartedFromClient_Success()
222 …Task<WebSocketReceiveResult> serverReceiveTask = context.WebSocket.ReceiveAsync(new ArraySegment<b… in CloseAsync_HandshakeStartedFromClient_Success()
238 …await Assert.ThrowsAsync<WebSocketException>(() => context.WebSocket.ReceiveAsync(new ArraySegment… in CloseAsync_HandshakeStartedFromClient_Success()
244 …Task<WebSocketReceiveResult> clientReceiveTask = Client.ReceiveAsync(new ArraySegment<byte>(receiv… in CloseAsync_HandshakeStartedFromClient_Success()
260 …await Assert.ThrowsAsync<WebSocketException>(() => context.WebSocket.ReceiveAsync(new ArraySegment… in CloseAsync_HandshakeStartedFromClient_Success()
342 … result = await webSocket.ReceiveAsync(new ArraySegment<byte>(buffer), CancellationToken.None); in ReceiveAllAsync()
|
| /dports/lang/mono/mono-5.10.1.57/mcs/class/System/Test/System.Net.WebSockets/ |
| H A D | ClientWebSocketTest.cs | 130 …var resp = socket.ReceiveAsync (new ArraySegment<byte> (receiveBuffer), CancellationToken.None).Re… in EchoTest()
151 …var resp = socket.ReceiveAsync (new ArraySegment<byte> (new byte[0]), CancellationToken.None).Resu… in CloseOutputAsyncTest()
194 socket.ReceiveAsync (new ArraySegment<byte> (new byte[0]), CancellationToken.None); in ReceiveAsyncArgTest_NotConnected()
202 socket.ReceiveAsync (new ArraySegment<byte> (), CancellationToken.None); in ReceiveAsyncArgTest_NoArray()
212 …Assert.IsTrue (socket.ReceiveAsync (new ArraySegment<byte> (new byte[0]), CancellationToken.None).… in ReceiveAsyncWrongState_Closed()
265 …ketRequestAsync<WebSocketReceiveResult> (async socket => await socket.ReceiveAsync (new ArraySegme… in SendAsyncEndOfMessageTest()
|
| /dports/lang/mono/mono-5.10.1.57/external/corefx/src/Common/tests/System/Net/Prerequisites/Servers/CoreFxNetCloudService/WebServer/WebSocket/ |
| H A D | EchoWebSocket.ashx.cs | 78 …var receiveResult = await socket.ReceiveAsync(new ArraySegment<byte>(receiveBuffer), CancellationT… in ProcessWebSocketRequest()
102 receiveResult = await socket.ReceiveAsync( in ProcessWebSocketRequest()
108 receiveResult = await socket.ReceiveAsync( in ProcessWebSocketRequest()
|
| /dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Net.WebSockets/src/System/Net/WebSockets/ |
| H A D | WebSocket.cs | 29 public abstract Task<WebSocketReceiveResult> ReceiveAsync(ArraySegment<byte> buffer, in ReceiveAsync() method in System.Net.WebSockets.WebSocket
36 …public virtual async ValueTask<ValueWebSocketReceiveResult> ReceiveAsync(Memory<byte> buffer, Canc… in ReceiveAsync() method in System.Net.WebSockets.WebSocket
40 …WebSocketReceiveResult r = await ReceiveAsync(arraySegment, cancellationToken).ConfigureAwait(fals… in ReceiveAsync()
48 …WebSocketReceiveResult r = await ReceiveAsync(new ArraySegment<byte>(array, 0, buffer.Length), can… in ReceiveAsync()
|