WebSocket

WebSockets\OwinWebSocketAdapter.cs (1)

30public class OwinWebSocketAdapter : WebSocket

TestWebSocket.cs (1)

8internal sealed class TestWebSocket : WebSocket

System\Net\Managed\WebSockets\HttpWebSocket.Managed.cs (1)

90private sealed class HttpListenerWrappedWebSocket : WebSocket

System\Net\WebSockets\ManagedWebSocket.cs (1)

30internal sealed partial class ManagedWebSocket : WebSocket

System\Net\WebSockets\ManagedWebSocket.KeepAlive.cs (1)

12internal sealed partial class ManagedWebSocket : WebSocket

System\Net\WebSockets\BrowserWebSockets\BrowserWebSocket.cs (1)

15internal sealed class BrowserWebSocket : WebSocket

System\Net\WebSockets\ClientWebSocket.cs (1)

12public sealed partial class ClientWebSocket : WebSocket

Terminal\TerminalWebSocketProxy.cs (7)

224using var socket = await context.WebSockets.AcceptWebSocketAsync().ConfigureAwait(false); 265using var socket = await context.WebSockets.AcceptWebSocketAsync().ConfigureAwait(false); 290private static async Task BridgeAsync(WebSocket socket, Hmp1WorkloadAdapter workload, Stream upstream, 325private static async Task PumpViewAsync(WebSocket socket, Hwt1PresentationAdapter presentation, Hmp1WorkloadAdapter workload, 491private static async Task CloseAsync(WebSocket socket, WebSocketCloseStatus status, string reason, Task? receive, ILogger logger) 521private static async Task SendFramesAsync(WebSocket socket, Hwt1PresentationAdapter presentation, 543private static async Task ReceiveMessagesAsync(WebSocket socket, Hwt1PresentationAdapter presentation,

Model\DashboardClientTests.cs (2)

68using var socket = await client.ConnectAsync( 191using var socket = await client.ConnectAsync(uri, CancellationToken.None).DefaultTimeout();

Terminal\TerminalWebSocketProxyEndpointTests.cs (1)

99using var socket = await client.ConnectAsync(BuildTerminalUri(useGrpc), timeout.Token);

Terminal\TerminalWebSocketTests.cs (5)

781private static async Task<string?> ReadFirstLogicalLineAsync(WebSocket socket, int requestId, CancellationToken cancellationToken) 814private static async Task<WebSocketReceiveResult> ReadCloseAsync(WebSocket socket, CancellationToken cancellationToken) 828private static Task SendAsync(WebSocket socket, string message, CancellationToken cancellationToken) 833private static async Task<JsonElement> ReadUntilAsync(WebSocket socket, Func<JsonElement, bool> predicate, CancellationToken cancellationToken) 846private static async Task<JsonElement> ReadFrameAsync(WebSocket socket, CancellationToken cancellationToken)

BrowserLogsCdpConnection.cs (4)

395WebSocket DetachConnectedWebSocket(); 414public WebSocket DetachConnectedWebSocket() 445internal sealed class BrowserLogsWebSocketCdpTransport(WebSocket webSocket, TimeSpan closeTimeout) : IBrowserLogsCdpTransport 448private readonly WebSocket _webSocket = webSocket;

BrowserLogsCdpConnectionTests.cs (11)

296private static async Task<ReceivedCommand> ReceiveCommandAsync(WebSocket socket) 345private static async Task<JsonDocument> ReceiveJsonDocumentAsync(WebSocket socket) 366private static Task SendTextAsync(WebSocket socket, string text) 475private sealed class ConnectedClientWebSocketConnector(WebSocket webSocket) : IClientWebSocketConnector 477private readonly WebSocket _webSocket = webSocket; 493public WebSocket DetachConnectedWebSocket() 520public WebSocket DetachConnectedWebSocket() 540ClientSocket = WebSocket.CreateFromStream(clientStream, isServer: false, subProtocol: null, keepAliveInterval: TimeSpan.FromSeconds(15)); 541ServerSocket = WebSocket.CreateFromStream(serverStream, isServer: true, subProtocol: null, keepAliveInterval: TimeSpan.FromSeconds(15)); 544public WebSocket ClientSocket { get; } 546public WebSocket ServerSocket { get; }

src\Aspire.Hosting.Browsers\BrowserLogsCdpConnection.cs (4)

395WebSocket DetachConnectedWebSocket(); 414public WebSocket DetachConnectedWebSocket() 445internal sealed class BrowserLogsWebSocketCdpTransport(WebSocket webSocket, TimeSpan closeTimeout) : IBrowserLogsCdpTransport 448private readonly WebSocket _webSocket = webSocket;

FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\ClientWebSocketFactory.cs (1)

23public abstract Task<WebSocket> CreateWebSocketAsync(Uri address, WebHeaderCollection headers, ICredentials credentials, WebSocketTransportSettings settings, TimeoutHelper timeoutHelper);

FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\ClientWebSocketTransportDuplexSessionChannel.cs (2)

190private async Task<WebSocket> CreateWebSocketWithFactoryAsync(X509Certificate2 certificate, TimeoutHelper timeoutHelper) 200WebSocket ws;

FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\CoreClrClientWebSocketFactory.cs (1)

16public override async Task<WebSocket> CreateWebSocketAsync(Uri address, WebHeaderCollection headers, ICredentials credentials,

FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\WebSocketTransportDuplexSessionChannel.cs (8)

23private WebSocket _webSocket; 40protected WebSocket WebSocket 465private WebSocket _webSocket; 478public WebSocketMessageSource(WebSocketTransportDuplexSessionChannel webSocketTransportDuplexSessionChannel, WebSocket webSocket, 486private void Initialize(WebSocketTransportDuplexSessionChannel webSocketTransportDuplexSessionChannel, WebSocket webSocket, bool useStreaming, IDefaultCommunicationTimeouts defaultTimeouts) 888private readonly WebSocket _webSocket; 907WebSocket webSocket, 924WebSocket webSocket,

DependencyInjection\ServerRazorComponentsBuilderExtensions.cs (2)

173public Task<WebSocket> AcceptAsync(WebSocketAcceptContext context) 194private async Task<WebSocket> ReturnAwaited(Task result, WebSocketAcceptContext context)

Internal\DefaultWebSocketManager.cs (2)

61public override Task<WebSocket> AcceptWebSocketAsync(string? subProtocol) 68public override Task<WebSocket> AcceptWebSocketAsync(WebSocketAcceptContext acceptContext)

WebSocketManager.cs (3)

30public virtual Task<WebSocket> AcceptWebSocketAsync() 40public abstract Task<WebSocket> AcceptWebSocketAsync(string? subProtocol); 47public virtual Task<WebSocket> AcceptWebSocketAsync(WebSocketAcceptContext acceptContext) => throw new NotImplementedException();

Internal\Transports\WebSocketsServerTransport.cs (5)

43using (var ws = await context.WebSockets.AcceptWebSocketAsync(subProtocol)) 60public async Task ProcessSocketAsync(WebSocket socket) 131private async Task StartReceiving(WebSocket socket) 200private async Task StartSending(WebSocket socket, bool ignoreFirstCancel) 301private static bool WebSocketCanSend(WebSocket ws)

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)

HttpConnectionOptions.cs (2)

68/// Gets or sets a delegate for wrapping or replacing the <see cref="WebSocket"/> 71public Func<WebSocketConnectionContext, CancellationToken, ValueTask<WebSocket>>? WebSocketFactory { get; set; }

Internal\WebSocketsTransport.cs (6)

32private WebSocket? _webSocket; 90private async ValueTask<WebSocket> DefaultWebSocketFactory(WebSocketConnectionContext context, CancellationToken cancellationToken) 337private async Task ProcessSocketAsync(WebSocket socket, Uri url, bool isReconnect) 433private async Task StartReceiving(WebSocket socket) 530private async Task StartSending(WebSocket socket, bool ignoreFirstCanceled) 633private static bool WebSocketCanSend(WebSocket ws)

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)

IHttpWebSocketFeature.cs (3)

19/// Attempts to upgrade the request to a <see cref="WebSocket"/>. Check <see cref="IsWebSocketRequest"/> 23/// <returns>A <see cref="WebSocket"/>.</returns> 24Task<WebSocket> AcceptAsync(WebSocketAcceptContext context);

OwinEnvironment.cs (1)

24Task<WebSocket>

OwinFeatureCollection.cs (2)

311Task<WebSocket> IHttpWebSocketFeature.AcceptAsync(WebSocketAcceptContext context) 318var accept = (Func<WebSocketAcceptContext, Task<WebSocket>>)obj;

WebSockets\OwinWebSocketAcceptAdapter.cs (4)

24Task<WebSocket> 35private readonly TaskCompletionSource<WebSocket> _acceptTcs = new TaskCompletionSource<WebSocket>(); 48private async Task<WebSocket> AcceptWebSocketAsync(WebSocketAcceptContext context)

WebSockets\WebSocketAcceptAdapter.cs (2)

24Task<WebSocket> 85var webSocket = await adapter._accept(acceptContext);

WebSockets\WebSocketAdapter.cs (3)

36private readonly WebSocket _webSocket; 40internal WebSocketAdapter(WebSocket webSocket, CancellationToken ct) 52_environment[typeof(WebSocket).FullName] = webSocket;

Proxying\SpaProxy.cs (3)

260using (var server = await context.WebSockets.AcceptWebSocketAsync(client.SubProtocol)) 272private static async Task PumpWebSocket(WebSocket source, WebSocket destination, int bufferSize, CancellationToken cancellationToken)

WebSocketClient.cs (4)

54public async Task<WebSocket> ConnectAsync(Uri uri, CancellationToken cancellationToken) 131public WebSocket? ClientWebSocket { get; private set; } 133public WebSocket? ServerWebSocket { get; private set; } 135async Task<WebSocket> IHttpWebSocketFeature.AcceptAsync(WebSocketAcceptContext context)

src\sdk\src\Dotnet.Watch\Web.Middleware\BrowserToolsForwarder.cs (3)

152using var browserSocket = await context.WebSockets.AcceptWebSocketAsync(providerSocket.SubProtocol); 256WebSocket source, 257WebSocket destination,

AbortStream.cs (2)

15/// This handles explicit <see cref="WebSocket.Abort"/> calls as well as the Keep-Alive timeout setting <see cref="WebSocketState.Aborted"/> and disposing the stream. 25public WebSocket? WebSocket { get; set; }

WebSocketMiddleware.cs (3)

132public async Task<WebSocket> AcceptAsync(WebSocketAcceptContext acceptContext) 214var wrappedSocket = WebSocket.CreateFromStream(abortStream, new WebSocketCreationOptions()

src\sdk\src\Dotnet.Watch\AspireService\AspireServerService.cs (1)

292var webSocket = await context.WebSockets.AcceptWebSocketAsync();

src\sdk\src\Dotnet.Watch\AspireService\Helpers\SocketConnectionManager.cs (1)

36public void AddSocketConnection(WebSocket socket, TaskCompletionSource tcs, string dcpId, CancellationToken httpRequestAborted)

src\sdk\src\Dotnet.Watch\AspireService\Helpers\WebSocketConnection.cs (2)

16internal sealed class WebSocketConnection(WebSocket socket, TaskCompletionSource tcs, string dcpId, CancellationToken httpRequestAborted) : IDisposable 18public WebSocket Socket { get; } = socket;

src\sdk\src\Dotnet.Watch\HotReloadClient\Web\BrowserConnection.cs (2)

20WebSocket clientSocket, 46public WebSocket ClientSocket => clientSocket;

src\sdk\src\Dotnet.Watch\HotReloadClient\Web\BrowserRefreshServer.cs (2)

288var clientSocket = await context.WebSockets.AcceptWebSocketAsync(subProtocol); 299protected BrowserConnection OnBrowserConnected(WebSocket clientSocket, string? sharedSecret)

src\sdk\src\Dotnet.Watch\HotReloadClient\WebSocketClientTransport.cs (3)

87public TaskCompletionSource<WebSocket?> ClientConnectedSource { get; } = new(); 89private WebSocket? _clientSocket; 155var webSocket = await context.WebSockets.AcceptWebSocketAsync(subProtocol);

netstandard.cs (1)

1312[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Net.WebSockets.WebSocket))]

parent\ref\System.cs (1)

803[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Net.WebSockets.WebSocket))]

System\Net\HttpListenerContext.cs (1)

27return AcceptWebSocketAsync(subProtocol, HttpWebSocket.DefaultReceiveBufferSize, WebSocket.DefaultKeepAliveInterval);

System\Net\Managed\WebSockets\HttpWebSocket.Managed.cs (4)

60WebSocket rawWebSocket = WebSocket.CreateFromStream(context.Connection.ConnectedStream, isServer: true, subProtocol, keepAliveInterval); 92private readonly WebSocket _inner; 96internal HttpListenerWrappedWebSocket(WebSocket inner, HttpListenerContext context)

System\Net\WebSockets\HttpListenerWebSocketContext.cs (3)

26private readonly WebSocket _webSocket; 40WebSocket webSocket) 87public override WebSocket WebSocket => _webSocket;

System\Net\WebSockets\ValueWebSocketReceiveResult.cs (2)

8/// <summary>Represents the result of performing a single <see cref="WebSocket.ReceiveAsync(Memory{byte}, System.Threading.CancellationToken)"/> operation on a <see cref="WebSocket"/>.</summary>

System\Net\WebSockets\WebSocket.cs (6)

126/// <summary>Creates a <see cref="WebSocket"/> that operates on a <see cref="Stream"/> representing a web socket connection.</summary> 131/// <returns>The created <see cref="WebSocket"/>.</returns> 132public static WebSocket CreateFromStream(Stream stream, bool isServer, string? subProtocol, TimeSpan keepAliveInterval) 156/// <summary>Creates a <see cref="WebSocket"/> that operates on a <see cref="Stream"/> representing a web socket connection.</summary> 159public static WebSocket CreateFromStream(Stream stream, WebSocketCreationOptions options) 184public static WebSocket CreateClientWebSocket(Stream innerStream,

System\Net\WebSockets\WebSocketContext.cs (1)

23public abstract WebSocket WebSocket { get; }

System\Net\WebSockets\WebSocketCreationOptions.cs (1)

9/// Options that control how a <seealso cref="WebSocket"/> is created.

System\Net\WebSockets\WebSocketDeflateOptions.cs (1)

7/// Options to enable per-message deflate compression for <seealso cref="WebSocket" />.

System\Net\WebSockets\WebSocketException.cs (4)

134$"{nameof(WebSocket)}.{nameof(WebSocket.CloseAsync)}", 135$"{nameof(WebSocket)}.{nameof(WebSocket.CloseOutputAsync)}"),

System\Net\WebSockets\WebSocketMessageFlags.cs (2)

7/// Flags for controlling how the <see cref="WebSocket"/> should send a message. 23/// Disables compression for the message if compression has been enabled for the <see cref="WebSocket"/> instance.

System\Net\WebSockets\WebSocketStateHelper.cs (1)

40ObjectDisposedException.ThrowIf(isDisposed, typeof(WebSocket));

System\Net\WebSockets\WebSocketStream.cs (9)

26private WebSocketStream(WebSocket webSocket) => WebSocket = webSocket; 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) 86public static WebSocketStream CreateReadableMessageStream(WebSocket webSocket) 95public WebSocket WebSocket { get; } 189private sealed class ReadWriteStream(WebSocket webSocket, WebSocketMessageType writeMessageType, TimeSpan? closeTimeout) : WebSocketStream(webSocket) 289private sealed class WriteMessageStream(WebSocket webSocket, WebSocketMessageType writeMessageType) : WebSocketStream(webSocket) 330private sealed class ReadMessageStream(WebSocket webSocket) : WebSocketStream(webSocket)

System\Net\WebSockets\ClientWebSocket.cs (1)

162private WebSocket ConnectedWebSocket

System\Net\WebSockets\WebSocketHandle.Browser.cs (1)

20public WebSocket? WebSocket { get; private set; }

System\ServiceModel\Channels\WebSocketTransportDuplexSessionChannel.cs (8)

20private WebSocket _webSocket; 37protected WebSocket WebSocket 449private WebSocket _webSocket; 462public WebSocketMessageSource(WebSocketTransportDuplexSessionChannel webSocketTransportDuplexSessionChannel, WebSocket webSocket, 470private void Initialize(WebSocketTransportDuplexSessionChannel webSocketTransportDuplexSessionChannel, WebSocket webSocket, bool useStreaming, IDefaultCommunicationTimeouts defaultTimeouts) 860private readonly WebSocket _webSocket; 879WebSocket webSocket, 896WebSocket webSocket,