165 references to WebSocketMessageType
Aspire.Dashboard (3)
Terminal\TerminalWebSocketProxy.cs (3)
505await socket.SendAsync(frame, WebSocketMessageType.Binary, true, timeout.Token).ConfigureAwait(false); 533if (result.MessageType == WebSocketMessageType.Close) 537if (result.MessageType != WebSocketMessageType.Text)
Aspire.Dashboard.Tests (16)
Model\DashboardClientTests.cs (3)
78await socket.SendAsync("""{"type":"input","text":"ignored"}"""u8.ToArray(), WebSocketMessageType.Text, 81Assert.Equal(WebSocketMessageType.Close, message.MessageType); 194Assert.Equal(WebSocketMessageType.Close, message.MessageType);
Terminal\TerminalWebSocketTests.cs (13)
180await browser.SendAsync(message.AsMemory(0, split), WebSocketMessageType.Text, false, timeout.Token); 181await browser.SendAsync(message.AsMemory(split), WebSocketMessageType.Text, true, timeout.Token); 211await browser.SendAsync(new byte[64 * 1024], WebSocketMessageType.Text, false, timeout.Token); 215await browser.SendAsync(new byte[] { 1 }, WebSocketMessageType.Binary, true, timeout.Token); 224while (result.MessageType != WebSocketMessageType.Close); 622Assert.Equal(WebSocketMessageType.Close, result.MessageType); 671Assert.Equal(WebSocketMessageType.Close, result.MessageType); 705Assert.Equal(WebSocketMessageType.Binary, frame.MessageType); 738Assert.Equal(WebSocketMessageType.Binary, initial.MessageType); 791if (result.MessageType == WebSocketMessageType.Close) 795Assert.Equal(WebSocketMessageType.Binary, result.MessageType); 801return socket.SendAsync(Encoding.UTF8.GetBytes(message), WebSocketMessageType.Text, true, cancellationToken); 814Assert.Equal(WebSocketMessageType.Binary, result.MessageType);
Aspire.Hosting.Browsers (2)
BrowserLogsCdpConnection.cs (2)
452await _webSocket.SendAsync(frame, WebSocketMessageType.Text, endOfMessage: true, cancellationToken).ConfigureAwait(false); 463if (result.MessageType == WebSocketMessageType.Close)
Aspire.Hosting.Browsers.Tests (4)
BrowserLogsCdpConnectionTests.cs (2)
353if (result.MessageType == WebSocketMessageType.Close) 368return socket.SendAsync(Encoding.UTF8.GetBytes(text), WebSocketMessageType.Text, endOfMessage: true, CancellationToken.None);
src\Aspire.Hosting.Browsers\BrowserLogsCdpConnection.cs (2)
452await _webSocket.SendAsync(frame, WebSocketMessageType.Text, endOfMessage: true, cancellationToken).ConfigureAwait(false); 463if (result.MessageType == WebSocketMessageType.Close)
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)
Microsoft.AspNetCore.Http.Connections (11)
Generated\Basic.CompilerLog.Util\Basic.CompilerLog.Util.Impl.BasicGeneratedFilesAnalyzerReference\LoggerMessage.g.cs (3)
904private static readonly global::System.Action<global::Microsoft.Extensions.Logging.ILogger, global::System.Net.WebSockets.WebSocketMessageType, int, bool, global::System.Exception?> __MessageReceivedCallback = 905global::Microsoft.Extensions.Logging.LoggerMessage.Define<global::System.Net.WebSockets.WebSocketMessageType, int, bool>(global::Microsoft.Extensions.Logging.LogLevel.Trace, new global::Microsoft.Extensions.Logging.EventId(9, "MessageReceived"), "Message received. Type: {MessageType}, size: {Size}, EndOfMessage: {EndOfMessage}.", new global::Microsoft.Extensions.Logging.LogDefineOptions() { SkipEnabledCheck = true }); 912public static partial void MessageReceived(global::Microsoft.Extensions.Logging.ILogger logger, global::System.Net.WebSockets.WebSocketMessageType messageType, int size, bool endOfMessage)
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\aspnetcore\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 (12)
Generated\Basic.CompilerLog.Util\Basic.CompilerLog.Util.Impl.BasicGeneratedFilesAnalyzerReference\LoggerMessage.g.cs (3)
1090private static readonly global::System.Action<global::Microsoft.Extensions.Logging.ILogger, global::System.Net.WebSockets.WebSocketMessageType, int, bool, global::System.Exception?> __MessageReceivedCallback = 1091global::Microsoft.Extensions.Logging.LoggerMessage.Define<global::System.Net.WebSockets.WebSocketMessageType, int, bool>(global::Microsoft.Extensions.Logging.LogLevel.Debug, new global::Microsoft.Extensions.Logging.EventId(12, "MessageReceived"), "Message received. Type: {MessageType}, size: {Count}, EndOfMessage: {EndOfMessage}.", new global::Microsoft.Extensions.Logging.LogDefineOptions() { SkipEnabledCheck = true }); 1098public static partial void MessageReceived(global::Microsoft.Extensions.Logging.ILogger logger, global::System.Net.WebSockets.WebSocketMessageType messageType, int count, bool endOfMessage)
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\aspnetcore\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.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.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.Watch.BrowserRefresh (1)
src\sdk\src\Dotnet.Watch\Web.Middleware\BrowserToolsForwarder.cs (1)
258if (result.MessageType == WebSocketMessageType.Close)
Microsoft.DotNet.HotReload.Watch (5)
src\sdk\src\Dotnet.Watch\AspireService\AspireServerService.cs (1)
407await connection.Socket.SendAsync(new ArraySegment<byte>(messageBytes), WebSocketMessageType.Text, endOfMessage: true, cancelTokenSource.Token);
src\sdk\src\Dotnet.Watch\HotReloadClient\Web\BrowserConnection.cs (2)
83await ClientSocket.SendAsync(data, WebSocketMessageType.Text, endOfMessage: true, cancellationToken); 118if (result.MessageType == WebSocketMessageType.Close)
src\sdk\src\Dotnet.Watch\HotReloadClient\WebSocketClientTransport.cs (2)
195WebSocketMessageType.Binary, 216if (result.MessageType == WebSocketMessageType.Close)
Microsoft.Extensions.DotNetDeltaApplier (2)
src\sdk\src\Dotnet.Watch\HotReloadAgent.Host\WebSocketTransport.cs (2)
84WebSocketMessageType.Binary, 108if (result.MessageType == WebSocketMessageType.Close)
netstandard (1)
netstandard.cs (1)
1317[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Net.WebSockets.WebSocketMessageType))]
System (1)
parent\ref\System.cs (1)
808[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Net.WebSockets.WebSocketMessageType))]
System.Net.HttpListener (1)
System\Net\Managed\WebSockets\HttpWebSocket.Managed.cs (1)
173WebSocketMessageType messageType,
System.Net.WebSockets (36)
System\Net\WebSockets\ManagedWebSocket.cs (16)
297public override Task SendAsync(ArraySegment<byte> buffer, WebSocketMessageType messageType, bool endOfMessage, CancellationToken cancellationToken) 308public override ValueTask SendAsync(ReadOnlyMemory<byte> buffer, WebSocketMessageType messageType, bool endOfMessage, CancellationToken cancellationToken) => 311public override ValueTask SendAsync(ReadOnlyMemory<byte> buffer, WebSocketMessageType messageType, WebSocketMessageFlags messageFlags, CancellationToken cancellationToken) 341opcode = messageType == WebSocketMessageType.Binary ? MessageOpcode.Binary : MessageOpcode.Text; 892return GetReceiveResult<TResult>(0, WebSocketMessageType.Close, true); 911messageType: header.Opcode == MessageOpcode.Text ? WebSocketMessageType.Text : WebSocketMessageType.Binary, 1007header.Opcode == MessageOpcode.Text ? WebSocketMessageType.Text : WebSocketMessageType.Binary, 1059private TResult GetReceiveResult<TResult>(int count, WebSocketMessageType messageType, bool endOfMessage) 1924internal static void ThrowIfInvalidMessageType(WebSocketMessageType messageType, [CallerArgumentExpression(nameof(messageType))] string? paramName = null) 1926if (messageType is not (WebSocketMessageType.Text or WebSocketMessageType.Binary)) 1931static void ThrowInvalidMessageType(WebSocketMessageType messageType, string? paramName) => 1934messageType, nameof(SendAsync), nameof(WebSocketMessageType.Binary), nameof(WebSocketMessageType.Text), nameof(CloseOutputAsync)),
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\WebSocketStream.cs (9)
35public static WebSocketStream Create(WebSocket webSocket, WebSocketMessageType writeMessageType, bool ownsWebSocket = false) 51public static WebSocketStream Create(WebSocket webSocket, WebSocketMessageType writeMessageType, TimeSpan closeTimeout) 71public static WebSocketStream CreateWritableMessageStream(WebSocket webSocket, WebSocketMessageType writeMessageType) 189private sealed class ReadWriteStream(WebSocket webSocket, WebSocketMessageType writeMessageType, TimeSpan? closeTimeout) : WebSocketStream(webSocket) 191private readonly WebSocketMessageType _messageType = writeMessageType; 230if (result.MessageType is WebSocketMessageType.Close) 289private sealed class WriteMessageStream(WebSocket webSocket, WebSocketMessageType writeMessageType) : WebSocketStream(webSocket) 291private readonly WebSocketMessageType _messageType = writeMessageType; 353if (result.MessageType is WebSocketMessageType.Close)
System.Net.WebSockets.Client (14)
System\Net\WebSockets\BrowserWebSockets\BrowserInterop.cs (1)
89public static unsafe Task? UnsafeSend(JSObject jsWs, MemoryHandle pinBuffer, int length, WebSocketMessageType messageType, bool endOfMessage)
System\Net\WebSockets\BrowserWebSockets\BrowserWebSocket.cs (10)
154public override Task SendAsync(ArraySegment<byte> buffer, WebSocketMessageType messageType, bool endOfMessage, CancellationToken cancellationToken) 157if (messageType != WebSocketMessageType.Binary && messageType != WebSocketMessageType.Text) 162WebSocketMessageType.Binary, 163WebSocketMessageType.Text, 369private async Task SendAsyncCore(ArraySegment<byte> buffer, WebSocketMessageType messageType, bool endOfMessage, CancellationToken cancellationToken) 472WebSocketMessageType messageType; 476messageType = (WebSocketMessageType)responseStatus[typeIndex]; 478if (messageType == WebSocketMessageType.Close) 486if (messageType == WebSocketMessageType.Close)
System\Net\WebSockets\ClientWebSocket.cs (3)
141public override Task SendAsync(ArraySegment<byte> buffer, WebSocketMessageType messageType, bool endOfMessage, CancellationToken cancellationToken) => 144public override ValueTask SendAsync(ReadOnlyMemory<byte> buffer, WebSocketMessageType messageType, bool endOfMessage, CancellationToken cancellationToken) => 147public override ValueTask SendAsync(ReadOnlyMemory<byte> buffer, WebSocketMessageType messageType, WebSocketMessageFlags messageFlags, CancellationToken cancellationToken) =>
System.ServiceModel.Http (13)
System\ServiceModel\Channels\HttpTransportDefaults.cs (2)
57internal const WebSocketMessageType DefaultWebSocketMessageType = WebSocketMessageType.Binary;
System\ServiceModel\Channels\WebSocketTransportDuplexSessionChannel.cs (11)
171WebSocketMessageType outgoingMessageType = GetWebSocketMessageType(message); 207WebSocketMessageType outgoingMessageType = GetWebSocketMessageType(message); 250WebSocketMessageType outgoingMessageType = GetWebSocketMessageType(message); 375private static WebSocketMessageType GetWebSocketMessageType(Message message) 678if (result.MessageType == WebSocketMessageType.Close) 801if (result.MessageType != WebSocketMessageType.Close) 832if (result.MessageType == WebSocketMessageType.Binary) 839Fx.Assert(result.MessageType == WebSocketMessageType.Text, "result.MessageType must be WebSocketMessageType.Text."); 867private readonly WebSocketMessageType _outgoingMessageType; 897WebSocketMessageType outgoingMessageType, 1213if (result.MessageType == WebSocketMessageType.Close)