|
|
|
@ -96,7 +96,7 @@ namespace Emby.Server.Implementations.HttpServer
|
|
|
|
|
/// <summary>
|
|
|
|
|
/// Sends a message asynchronously.
|
|
|
|
|
/// </summary>
|
|
|
|
|
/// <typeparam name="T"></typeparam>
|
|
|
|
|
/// <typeparam name="T">The type of the message.</typeparam>
|
|
|
|
|
/// <param name="message">The message.</param>
|
|
|
|
|
/// <param name="cancellationToken">The cancellation token.</param>
|
|
|
|
|
/// <returns>Task.</returns>
|
|
|
|
@ -150,8 +150,8 @@ namespace Emby.Server.Implementations.HttpServer
|
|
|
|
|
{
|
|
|
|
|
await ProcessInternal(pipe.Reader).ConfigureAwait(false);
|
|
|
|
|
}
|
|
|
|
|
} while (
|
|
|
|
|
(_socket.State == WebSocketState.Open || _socket.State == WebSocketState.Connecting)
|
|
|
|
|
}
|
|
|
|
|
while ((_socket.State == WebSocketState.Open || _socket.State == WebSocketState.Connecting)
|
|
|
|
|
&& receiveresult.MessageType != WebSocketMessageType.Close);
|
|
|
|
|
|
|
|
|
|
Closed?.Invoke(this, EventArgs.Empty);
|
|
|
|
|