ReceiveAsync() [2/2]

virtual async ValueTask< ValueWebSocketReceiveResult > System.Net.WebSockets.WebSocket.ReceiveAsync ( Memory< byte > buffer, CancellationToken cancellationToken )

inlinevirtualinherited

Reimplemented in System.Net.WebSockets.ClientWebSocket, and System.Net.WebSockets.ManagedWebSocket.

Definition at line 34 of file WebSocket.cs.

    {
        if (MemoryMarshal.TryGetArray((ReadOnlyMemory<byte>)buffer, out ArraySegment<byte> segment))
        {
            WebSocketReceiveResult webSocketReceiveResult = await ReceiveAsync(segment, cancellationToken).ConfigureAwait(continueOnCapturedContext: false);
            return new ValueWebSocketReceiveResult(webSocketReceiveResult.Count, webSocketReceiveResult.MessageType, webSocketReceiveResult.EndOfMessage);
        }
        byte[] array = ArrayPool<byte>.Shared.Rent(buffer.Length);
        try
        {
            WebSocketReceiveResult webSocketReceiveResult2 = await ReceiveAsync(new ArraySegment<byte>(array, 0, buffer.Length), cancellationToken).ConfigureAwait(continueOnCapturedContext: false);
            new Span<byte>(array, 0, webSocketReceiveResult2.Count).CopyTo(buffer.Span);
            return new ValueWebSocketReceiveResult(webSocketReceiveResult2.Count, webSocketReceiveResult2.MessageType, webSocketReceiveResult2.EndOfMessage);
        }
        finally
        {
            ArrayPool<byte>.Shared.Return(array);
        }
    }

References System.array, System.buffer, System.cancellationToken, System.Span< T >.CopyTo(), System.Net.WebSockets.WebSocketReceiveResult.Count, System.Net.WebSockets.WebSocketReceiveResult.EndOfMessage, System.Net.WebSockets.WebSocketReceiveResult.MessageType, System.Net.WebSockets.WebSocket.ReceiveAsync(), and System.Buffers.ArrayPool< T >.Shared.