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

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)

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);

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)

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

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

18public WebSocketConnection(WebSocket socket, TaskCompletionSource tcs, string dcpId, CancellationToken httpRequestAborted) 26public WebSocket Socket { get; }

src\sdk\src\Dotnet.Watch\HotReloadClient\Web\AbstractBrowserRefreshServer.cs (1)

105protected BrowserConnection OnBrowserConnected(WebSocket clientSocket, string? subProtocol)

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

22public WebSocket ClientSocket { get; } 30public BrowserConnection(WebSocket clientSocket, string? sharedSecret, ILoggerFactory loggerFactory)

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

63var clientSocket = await context.WebSockets.AcceptWebSocketAsync(subProtocol);

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

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

netstandard.cs (1)

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

src\runtime\src\libraries\shims\System\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,