192 references to WebSocketMessageType
dotnet-svcutil-lib (13)
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\TransportDefaults.cs (2)
359internal const WebSocketMessageType DefaultWebSocketMessageType = WebSocketMessageType.Binary;
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\WebSocketTransportDuplexSessionChannel.cs (11)
192WebSocketMessageType outgoingMessageType = GetWebSocketMessageType(message); 228WebSocketMessageType outgoingMessageType = GetWebSocketMessageType(message); 271WebSocketMessageType outgoingMessageType = GetWebSocketMessageType(message); 391private static WebSocketMessageType GetWebSocketMessageType(Message message) 706if (result.MessageType == WebSocketMessageType.Close) 829if (result.MessageType != WebSocketMessageType.Close) 860if (result.MessageType == WebSocketMessageType.Binary) 867Fx.Assert(result.MessageType == WebSocketMessageType.Text, "result.MessageType must be WebSocketMessageType.Text."); 895private readonly WebSocketMessageType _outgoingMessageType; 925WebSocketMessageType outgoingMessageType, 1241if (result.MessageType == WebSocketMessageType.Close)
ExceptionHandlerSample (1)
StartupWithWebSocket.cs (1)
32await ws.SendAsync(new ArraySegment<byte>(Encoding.UTF8.GetBytes("Hello")), System.Net.WebSockets.WebSocketMessageType.Text, true, context.RequestAborted);
IIS.FunctionalTests (1)
src\Servers\IIS\IIS\test\Common.FunctionalTests\WebSocketTests.cs (1)
190await webSocket.SendAsync(new ArraySegment<byte>(Encoding.ASCII.GetBytes(message)), WebSocketMessageType.Text, true, default);
IISExpress.FunctionalTests (1)
src\Servers\IIS\IIS\test\Common.FunctionalTests\WebSocketTests.cs (1)
190await webSocket.SendAsync(new ArraySegment<byte>(Encoding.ASCII.GetBytes(message)), WebSocketMessageType.Text, true, default);
InProcessWebSite (1)
src\Servers\IIS\IIS\test\testassets\InProcessWebSite\Startup.WebSockets.cs (1)
138await webSocket.SendAsync(new ArraySegment<byte>(Encoding.ASCII.GetBytes(message)), WebSocketMessageType.Text, true, CancellationToken.None);
Interop.FunctionalTests (4)
Http2WebSocketInteropTests.cs (4)
67Assert.Equal(WebSocketMessageType.Text, result.MessageType); 70await ws.SendAsync(Encoding.UTF8.GetBytes("Hi there"), WebSocketMessageType.Text, endOfMessage: true, default); 86await wsClient.SendAsync(Encoding.UTF8.GetBytes("Hello"), WebSocketMessageType.Text, endOfMessage: true, default); 91Assert.Equal(WebSocketMessageType.Text, result.MessageType);
Microsoft.AspNetCore.Http.Connections (8)
Internal\Transports\WebSocketsServerTransport.cs (5)
142if (result.MessageType == WebSocketMessageType.Close) 153if (receiveResult.MessageType == WebSocketMessageType.Close) 228var webSocketMessageType = (_connection.ActiveFormat == TransferFormat.Binary 229? WebSocketMessageType.Binary 230: WebSocketMessageType.Text);
Internal\Transports\WebSocketsServerTransport.Log.cs (1)
38public static partial void MessageReceived(ILogger logger, WebSocketMessageType messageType, int size, bool endOfMessage);
src\SignalR\common\Shared\WebSocketExtensions.cs (2)
14public static ValueTask SendAsync(this WebSocket webSocket, ReadOnlySequence<byte> buffer, WebSocketMessageType webSocketMessageType, CancellationToken cancellationToken = default) 39private static async ValueTask SendMultiSegmentAsync(WebSocket webSocket, ReadOnlySequence<byte> buffer, WebSocketMessageType webSocketMessageType, CancellationToken cancellationToken = default)
Microsoft.AspNetCore.Http.Connections.Client (9)
Internal\WebSocketsTransport.cs (6)
34private WebSocketMessageType _webSocketMessageType; 297? WebSocketMessageType.Binary 298: WebSocketMessageType.Text; 409await StartAsync(url, _webSocketMessageType == WebSocketMessageType.Binary ? TransferFormat.Binary : TransferFormat.Text, 445if (result.MessageType == WebSocketMessageType.Close) 472if (receiveResult.MessageType == WebSocketMessageType.Close)
Internal\WebSocketsTransport.Log.cs (1)
49public static partial void MessageReceived(ILogger logger, WebSocketMessageType messageType, int count, bool endOfMessage);
src\SignalR\common\Shared\WebSocketExtensions.cs (2)
14public static ValueTask SendAsync(this WebSocket webSocket, ReadOnlySequence<byte> buffer, WebSocketMessageType webSocketMessageType, CancellationToken cancellationToken = default) 39private static async ValueTask SendMultiSegmentAsync(WebSocket webSocket, ReadOnlySequence<byte> buffer, WebSocketMessageType webSocketMessageType, CancellationToken cancellationToken = default)
Microsoft.AspNetCore.Http.Connections.Tests (19)
MapConnectionHandlerTests.cs (1)
406Assert.Equal(WebSocketMessageType.Close, result.MessageType);
TestWebSocketConnectionFeature.cs (9)
100MessageType = WebSocketMessageType.Close, 115MessageType = WebSocketMessageType.Close, 140if (message.MessageType == WebSocketMessageType.Close) 145return new WebSocketReceiveResult(0, WebSocketMessageType.Close, true, message.CloseStatus, message.CloseStatusDescription); 191public override async Task SendAsync(ArraySegment<byte> buffer, WebSocketMessageType messageType, bool endOfMessage, CancellationToken cancellationToken) 223MessageType = WebSocketMessageType.Close, 237if (message.MessageType == WebSocketMessageType.Close) 250return new WebSocketConnectionSummary(frames, new WebSocketReceiveResult(0, WebSocketMessageType.Close, endOfMessage: true, closeStatus: WebSocketCloseStatus.InternalServerError, closeStatusDescription: "")); 280public WebSocketMessageType MessageType { get; set; }
WebSocketsTests.cs (9)
27[InlineData(nameof(WebSocketMessageType.Text))] 28[InlineData(nameof(WebSocketMessageType.Binary))] 49messageType: (WebSocketMessageType)Enum.Parse(typeof(WebSocketMessageType), webSocketMessageType), 74[InlineData(TransferFormat.Text, nameof(WebSocketMessageType.Text))] 75[InlineData(TransferFormat.Binary, nameof(WebSocketMessageType.Binary))] 105Assert.Equal((WebSocketMessageType)Enum.Parse(typeof(WebSocketMessageType), expectedMessageType), clientSummary.Received[0].MessageType); 407await serverSocket.SendAsync(sequence, WebSocketMessageType.Text);
Microsoft.AspNetCore.Owin (20)
WebSockets\OwinWebSocketAdapter.cs (11)
105var messageType = OpCodeToEnum(rawResult.Item1); 106if (messageType == WebSocketMessageType.Close) 125public override Task SendAsync(ArraySegment<byte> buffer, WebSocketMessageType messageType, bool endOfMessage, CancellationToken cancellationToken) 180private static WebSocketMessageType OpCodeToEnum(int messageType) 185return WebSocketMessageType.Text; 187return WebSocketMessageType.Binary; 189return WebSocketMessageType.Close; 195private static int EnumToOpCode(WebSocketMessageType webSocketMessageType) 199case WebSocketMessageType.Text: 201case WebSocketMessageType.Binary: 203case WebSocketMessageType.Close:
WebSockets\WebSocketAdapter.cs (9)
80if (nativeResult.MessageType == WebSocketMessageType.Close) 140private static WebSocketMessageType OpCodeToEnum(int messageType) 145return WebSocketMessageType.Text; 147return WebSocketMessageType.Binary; 149return WebSocketMessageType.Close; 155private static int EnumToOpCode(WebSocketMessageType webSocketMessageType) 159case WebSocketMessageType.Text: 161case WebSocketMessageType.Binary: 163case WebSocketMessageType.Close:
Microsoft.AspNetCore.SignalR.Client.Tests (2)
WebSocketsTransportTests.cs (2)
70return new WebSocketReceiveResult(0, WebSocketMessageType.Text, true); 73public override async Task SendAsync(ArraySegment<byte> buffer, WebSocketMessageType messageType, bool endOfMessage, CancellationToken cancellationToken)
Microsoft.AspNetCore.SignalR.Tests (5)
EndToEndTests.cs (4)
104await ws.SendAsync(new ArraySegment<byte>(bytes), WebSocketMessageType.Binary, endOfMessage: true, CancellationToken.None).DefaultTimeout(); 117Assert.Equal(WebSocketMessageType.Close, result.MessageType); 143await ws.SendAsync(new ArraySegment<byte>(bytes), WebSocketMessageType.Binary, endOfMessage: false, CancellationToken.None).DefaultTimeout(); 156Assert.Equal(WebSocketMessageType.Close, result.MessageType);
WebSocketsTransportTests.cs (1)
72.ReturnsAsync(new ValueWebSocketReceiveResult(0, WebSocketMessageType.Close, true));
Microsoft.AspNetCore.SpaServices.Extensions (1)
Proxying\SpaProxy.cs (1)
300if (result.MessageType == WebSocketMessageType.Close)
Microsoft.AspNetCore.TestHost (9)
TestWebSocket.cs (9)
65while (result.MessageType != WebSocketMessageType.Close); 123if (receiveMessage.MessageType == WebSocketMessageType.Close) 127var result = new WebSocketReceiveResult(0, WebSocketMessageType.Close, true, _closeStatus, _closeStatusDescription); 154public override Task SendAsync(ArraySegment<byte> buffer, WebSocketMessageType messageType, bool endOfMessage, CancellationToken cancellationToken) 157if (messageType != WebSocketMessageType.Binary && messageType != WebSocketMessageType.Text) 220public Message(ArraySegment<byte> buffer, WebSocketMessageType messageType, bool endOfMessage) 234MessageType = WebSocketMessageType.Close; 242public WebSocketMessageType MessageType { get; set; }
Microsoft.AspNetCore.TestHost.Tests (11)
TestClientTests.cs (9)
588if (receiveResult.MessageType == WebSocketMessageType.Close) 617await clientSocket.SendAsync(new System.ArraySegment<byte>(hello), WebSocketMessageType.Text, true, CancellationToken.None); 619await clientSocket.SendAsync(new System.ArraySegment<byte>(world), WebSocketMessageType.Binary, true, CancellationToken.None); 629Assert.Equal(WebSocketMessageType.Text, result.MessageType); 634Assert.Equal(WebSocketMessageType.Binary, result.MessageType); 637Assert.Equal(WebSocketMessageType.Close, result.MessageType); 687Assert.Equal(WebSocketMessageType.Close, result.MessageType); 710if (receiveResult.MessageType == WebSocketMessageType.Close) 809await clientSocket.SendAsync(new System.ArraySegment<byte>(hello), WebSocketMessageType.Text, true, CancellationToken.None);
WebSocketClientTests.cs (2)
72await websocket.SendAsync(buffer.AsMemory(0, res.Count), System.Net.WebSockets.WebSocketMessageType.Binary, true, default); 85await socket.SendAsync(new byte[10], System.Net.WebSockets.WebSocketMessageType.Binary, true, default);
Microsoft.AspNetCore.WebSockets.Tests (47)
SendReceiveTests.cs (10)
19await pair.ClientSocket.SendAsync(new ArraySegment<byte>(sendBuffer), WebSocketMessageType.Text, endOfMessage: true, cancellationToken: CancellationToken.None); 24Assert.Equal(WebSocketMessageType.Text, result.MessageType); 36await pair.ServerSocket.SendAsync(new ArraySegment<byte>(sendBuffer), WebSocketMessageType.Text, endOfMessage: true, cancellationToken: CancellationToken.None); 41Assert.Equal(WebSocketMessageType.Text, result.MessageType); 51await pair.ClientSocket.SendAsync(new ArraySegment<byte>(sendBuffer), WebSocketMessageType.Binary, endOfMessage: true, cancellationToken: CancellationToken.None); 56Assert.Equal(WebSocketMessageType.Binary, result.MessageType); 66await pair.ServerSocket.SendAsync(new ArraySegment<byte>(sendBuffer), WebSocketMessageType.Binary, endOfMessage: true, cancellationToken: CancellationToken.None); 71Assert.Equal(WebSocketMessageType.Binary, result.MessageType); 81await pair.ServerSocket.SendAsync(new ArraySegment<byte>(sendBuffer), WebSocketMessageType.Binary, endOfMessage: true, cancellationToken: CancellationToken.None); 86Assert.Equal(WebSocketMessageType.Binary, result.MessageType);
WebSocketCompressionMiddlewareTests.cs (2)
126if (result.MessageType == WebSocketMessageType.Close) 147await client.SendAsync(clientBuf.AsMemory(0, sendCount), WebSocketMessageType.Binary, true, default);
WebSocketMiddlewareTests.cs (35)
74Assert.Equal(WebSocketMessageType.Binary, result.MessageType); 81await client.SendAsync(new ArraySegment<byte>(originalData), WebSocketMessageType.Binary, true, CancellationToken.None); 99Assert.Equal(WebSocketMessageType.Binary, result.MessageType); 106await client.SendAsync(new ArraySegment<byte>(originalData), WebSocketMessageType.Binary, true, CancellationToken.None); 124Assert.Equal(WebSocketMessageType.Binary, result.MessageType); 131await client.SendAsync(new ArraySegment<byte>(originalData), WebSocketMessageType.Binary, true, CancellationToken.None); 149Assert.Equal(WebSocketMessageType.Binary, result.MessageType); 159await client.SendAsync(new ArraySegment<byte>(originalData), WebSocketMessageType.Binary, true, CancellationToken.None); 182Assert.Equal(WebSocketMessageType.Binary, result.MessageType); 190Assert.Equal(WebSocketMessageType.Binary, result.MessageType); 198Assert.Equal(WebSocketMessageType.Binary, result.MessageType); 206await client.SendAsync(new ArraySegment<byte>(originalData, 0, 2), WebSocketMessageType.Binary, false, CancellationToken.None); 209await client.SendAsync(new ArraySegment<byte>(originalData, 2, 2), WebSocketMessageType.Binary, false, CancellationToken.None); 212await client.SendAsync(new ArraySegment<byte>(originalData, 4, 7), WebSocketMessageType.Binary, true, CancellationToken.None); 226await webSocket.SendAsync(new ArraySegment<byte>(originalData), WebSocketMessageType.Binary, true, CancellationToken.None); 236Assert.Equal(WebSocketMessageType.Binary, result.MessageType); 251await webSocket.SendAsync(new ArraySegment<byte>(originalData), WebSocketMessageType.Binary, true, CancellationToken.None); 261Assert.Equal(WebSocketMessageType.Binary, result.MessageType); 276await webSocket.SendAsync(new ArraySegment<byte>(originalData), WebSocketMessageType.Binary, true, CancellationToken.None); 289Assert.Equal(WebSocketMessageType.Binary, result.MessageType); 294Assert.Equal(WebSocketMessageType.Binary, result.MessageType); 309await webSocket.SendAsync(new ArraySegment<byte>(originalData, 0, 2), WebSocketMessageType.Binary, false, CancellationToken.None); 310await webSocket.SendAsync(new ArraySegment<byte>(originalData, 2, 2), WebSocketMessageType.Binary, false, CancellationToken.None); 311await webSocket.SendAsync(new ArraySegment<byte>(originalData, 4, 7), WebSocketMessageType.Binary, true, CancellationToken.None); 322Assert.Equal(WebSocketMessageType.Binary, result.MessageType); 329Assert.Equal(WebSocketMessageType.Binary, result.MessageType); 336Assert.Equal(WebSocketMessageType.Binary, result.MessageType); 356Assert.Equal(WebSocketMessageType.Close, result.MessageType); 390Assert.Equal(WebSocketMessageType.Close, result.MessageType); 412Assert.Equal(WebSocketMessageType.Close, result.MessageType); 442Assert.Equal(WebSocketMessageType.Close, result.MessageType); 476Assert.Equal(WebSocketMessageType.Close, result.MessageType); 488Assert.Equal(WebSocketMessageType.Close, result.MessageType); 563await client.SendAsync(clientBuffer, WebSocketMessageType.Binary, false, default); 630await client.SendAsync(clientBuffer, WebSocketMessageType.Binary, false, default);
netstandard (1)
netstandard.cs (1)
1317[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Net.WebSockets.WebSocketMessageType))]
System (1)
src\libraries\shims\System\ref\System.cs (1)
808[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Net.WebSockets.WebSocketMessageType))]
System.Net.WebSockets (31)
System\Net\WebSockets\ManagedWebSocket.cs (20)
297public override Task SendAsync(ArraySegment<byte> buffer, WebSocketMessageType messageType, bool endOfMessage, CancellationToken cancellationToken) 301if (messageType != WebSocketMessageType.Text && messageType != WebSocketMessageType.Binary) 305nameof(WebSocketMessageType.Close), nameof(SendAsync), nameof(WebSocketMessageType.Binary), nameof(WebSocketMessageType.Text), nameof(CloseOutputAsync)), 314public override ValueTask SendAsync(ReadOnlyMemory<byte> buffer, WebSocketMessageType messageType, bool endOfMessage, CancellationToken cancellationToken) => 317public override ValueTask SendAsync(ReadOnlyMemory<byte> buffer, WebSocketMessageType messageType, WebSocketMessageFlags messageFlags, CancellationToken cancellationToken) 321if (messageType != WebSocketMessageType.Text && messageType != WebSocketMessageType.Binary) 325nameof(WebSocketMessageType.Close), nameof(SendAsync), nameof(WebSocketMessageType.Binary), nameof(WebSocketMessageType.Text), nameof(CloseOutputAsync)), 353opcode = messageType == WebSocketMessageType.Binary ? MessageOpcode.Binary : MessageOpcode.Text; 883return GetReceiveResult<TResult>(0, WebSocketMessageType.Close, true); 902messageType: header.Opcode == MessageOpcode.Text ? WebSocketMessageType.Text : WebSocketMessageType.Binary, 999header.Opcode == MessageOpcode.Text ? WebSocketMessageType.Text : WebSocketMessageType.Binary, 1051private TResult GetReceiveResult<TResult>(int count, WebSocketMessageType messageType, bool endOfMessage)
System\Net\WebSockets\ValueWebSocketReceiveResult.cs (4)
12private readonly WebSocketMessageType _messageType; 18public ValueWebSocketReceiveResult(int count, WebSocketMessageType messageType, bool endOfMessage) 21if ((uint)messageType > (uint)WebSocketMessageType.Close) ThrowMessageTypeOutOfRange(); 33public WebSocketMessageType MessageType => _messageType;
System\Net\WebSockets\WebSocket.cs (4)
31WebSocketMessageType messageType, 56public virtual ValueTask SendAsync(ReadOnlyMemory<byte> buffer, WebSocketMessageType messageType, bool endOfMessage, CancellationToken cancellationToken) => 61public virtual ValueTask SendAsync(ReadOnlyMemory<byte> buffer, WebSocketMessageType messageType, WebSocketMessageFlags messageFlags, CancellationToken cancellationToken = default) 68WebSocketMessageType messageType,
System\Net\WebSockets\WebSocketReceiveResult.cs (3)
10public WebSocketReceiveResult(int count, WebSocketMessageType messageType, bool endOfMessage) 16WebSocketMessageType messageType, 32public WebSocketMessageType MessageType { get; }
System.Net.WebSockets.Client (3)
System\Net\WebSockets\ClientWebSocket.cs (3)
145public override Task SendAsync(ArraySegment<byte> buffer, WebSocketMessageType messageType, bool endOfMessage, CancellationToken cancellationToken) => 148public override ValueTask SendAsync(ReadOnlyMemory<byte> buffer, WebSocketMessageType messageType, bool endOfMessage, CancellationToken cancellationToken) => 151public override ValueTask SendAsync(ReadOnlyMemory<byte> buffer, WebSocketMessageType messageType, WebSocketMessageFlags messageFlags, CancellationToken cancellationToken) =>
WebSocketSample (4)
Program.cs (4)
38await ws.SendAsync(new ArraySegment<byte>(bytes), WebSocketMessageType.Text, endOfMessage: true, cancellationToken: CancellationToken.None); 57if (result.MessageType == WebSocketMessageType.Text) 61else if (result.MessageType == WebSocketMessageType.Binary) 64else if (result.MessageType == WebSocketMessageType.Close)