5 instantiations of WebSocketMessage
Microsoft.AspNetCore.Http.Connections.Tests (5)
TestWebSocketConnectionFeature.cs (5)
66private WebSocketMessage _internalBuffer = new WebSocketMessage(); 96await SendMessageAsync(new WebSocketMessage 111await SendMessageAsync(new WebSocketMessage 201await SendMessageAsync(new WebSocketMessage 220return new WebSocketMessage()
17 references to WebSocketMessage
Microsoft.AspNetCore.Http.Connections.Tests (17)
HttpConnectionDispatcherTests.cs (2)
2405var webSocketMessage = await websocketFeature.Client.GetNextMessageAsync().DefaultTimeout(); 2479var webSocketMessage = await websocketFeature.Client.GetNextMessageAsync().DefaultTimeout();
TestWebSocketConnectionFeature.cs (15)
40var clientToServer = Channel.CreateUnbounded<WebSocketMessage>(); 41var serverToClient = Channel.CreateUnbounded<WebSocketMessage>(); 59private readonly ChannelReader<WebSocketMessage> _input; 60private readonly ChannelWriter<WebSocketMessage> _output; 66private WebSocketMessage _internalBuffer = new WebSocketMessage(); 68public WebSocketChannel(ChannelReader<WebSocketMessage> input, ChannelWriter<WebSocketMessage> output, SyncPoint sync = null) 138if (_input.TryRead(out var message)) 210public async Task<WebSocketMessage> GetNextMessageAsync() 214if (_input.TryRead(out var message)) 232var frames = new List<WebSocketMessage>(); 235while (_input.TryRead(out var message)) 253private async Task SendMessageAsync(WebSocketMessage webSocketMessage, CancellationToken cancellationToken) 267public IList<WebSocketMessage> Received { get; } 270public WebSocketConnectionSummary(IList<WebSocketMessage> received, WebSocketReceiveResult closeResult)