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

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)

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)

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

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

18internal readonly struct BrowserConnection(WebSocket clientSocket, string? sharedSecret, int id, ILogger serverLogger, ILogger agentLogger) : IDisposable 30public WebSocket ClientSocket => clientSocket;

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

64var 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,