diff options
Diffstat (limited to 'MediaBrowser.Server.Implementations/WebSocket/FleckWebSocket.cs')
| -rw-r--r-- | MediaBrowser.Server.Implementations/WebSocket/FleckWebSocket.cs | 47 |
1 files changed, 0 insertions, 47 deletions
diff --git a/MediaBrowser.Server.Implementations/WebSocket/FleckWebSocket.cs b/MediaBrowser.Server.Implementations/WebSocket/FleckWebSocket.cs deleted file mode 100644 index 3667fab07..000000000 --- a/MediaBrowser.Server.Implementations/WebSocket/FleckWebSocket.cs +++ /dev/null @@ -1,47 +0,0 @@ -using MediaBrowser.Common.Net; -using MediaBrowser.Model.Net; -using System; -using System.Threading; -using System.Threading.Tasks; -using IWebSocketConnection = Fleck.IWebSocketConnection; - -namespace MediaBrowser.Server.Implementations.WebSocket -{ - public class FleckWebSocket : IWebSocket - { - private readonly IWebSocketConnection _connection; - - public FleckWebSocket(IWebSocketConnection connection) - { - _connection = connection; - - _connection.OnMessage = OnReceiveData; - } - - public WebSocketState State - { - get { return _connection.IsAvailable ? WebSocketState.Open : WebSocketState.Closed; } - } - - private void OnReceiveData(string data) - { - if (OnReceive != null) - { - OnReceive(data); - } - } - - public Task SendAsync(byte[] bytes, WebSocketMessageType type, bool endOfMessage, CancellationToken cancellationToken) - { - return Task.Run(() => _connection.Send(bytes)); - } - - public void Dispose() - { - _connection.Close(); - } - - public Action<byte[]> OnReceiveBytes { get; set; } - public Action<string> OnReceive { get; set; } - } -} |
