| | | 1 | | // Licensed to the .NET Foundation under one or more agreements. |
| | | 2 | | // The .NET Foundation licenses this file to you under the MIT license. |
| | | 3 | | |
| | | 4 | | using System.Diagnostics; |
| | | 5 | | |
| | | 6 | | namespace System.Net.WebSockets |
| | | 7 | | { |
| | | 8 | | /// <summary>Represents the result of performing a single <see cref="WebSocket.ReceiveAsync(Memory{byte}, System.Thr |
| | | 9 | | public readonly struct ValueWebSocketReceiveResult |
| | | 10 | | { |
| | | 11 | | private readonly uint _countAndEndOfMessage; |
| | | 12 | | private readonly WebSocketMessageType _messageType; |
| | | 13 | | |
| | | 14 | | /// <summary>Creates an instance of the <see cref="ValueWebSocketReceiveResult"/> value type.</summary> |
| | | 15 | | /// <param name="count">The number of bytes received.</param> |
| | | 16 | | /// <param name="messageType">The type of message that was received.</param> |
| | | 17 | | /// <param name="endOfMessage">Whether this is the final message.</param> |
| | | 18 | | public ValueWebSocketReceiveResult(int count, WebSocketMessageType messageType, bool endOfMessage) |
| | 168533 | 19 | | { |
| | 168533 | 20 | | ArgumentOutOfRangeException.ThrowIfNegative(count); |
| | 168533 | 21 | | if ((uint)messageType > (uint)WebSocketMessageType.Close) ThrowMessageTypeOutOfRange(); |
| | | 22 | | |
| | 168533 | 23 | | _countAndEndOfMessage = (uint)count | (uint)(endOfMessage ? 1 << 31 : 0); |
| | 168533 | 24 | | _messageType = messageType; |
| | | 25 | | |
| | 168533 | 26 | | Debug.Assert(count == Count); |
| | 168533 | 27 | | Debug.Assert(messageType == MessageType); |
| | 168533 | 28 | | Debug.Assert(endOfMessage == EndOfMessage); |
| | 168533 | 29 | | } |
| | | 30 | | |
| | 168533 | 31 | | public int Count => (int)(_countAndEndOfMessage & 0x7FFFFFFF); |
| | 168533 | 32 | | public bool EndOfMessage => (_countAndEndOfMessage & 0x80000000) == 0x80000000; |
| | 168533 | 33 | | public WebSocketMessageType MessageType => _messageType; |
| | | 34 | | |
| | 0 | 35 | | private static void ThrowMessageTypeOutOfRange() => throw new ArgumentOutOfRangeException("messageType"); |
| | | 36 | | } |
| | | 37 | | } |