aboutsummaryrefslogtreecommitdiff
path: root/MediaBrowser.Server.Implementations/WebSocket/FleckWebSocket.cs
diff options
context:
space:
mode:
authorLuke Pulverenti <luke.pulverenti@gmail.com>2014-02-25 23:38:21 -0500
committerLuke Pulverenti <luke.pulverenti@gmail.com>2014-02-25 23:38:21 -0500
commit13563b604756152fe2f6630a4cb8fd2994e5bb62 (patch)
tree367a886bcb57360e635da48046c87eaff243625d /MediaBrowser.Server.Implementations/WebSocket/FleckWebSocket.cs
parent7767580a3bff0d3a6ddc36b32784c0d49bb6b5f7 (diff)
Add upnp configuration
Diffstat (limited to 'MediaBrowser.Server.Implementations/WebSocket/FleckWebSocket.cs')
-rw-r--r--MediaBrowser.Server.Implementations/WebSocket/FleckWebSocket.cs47
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; }
- }
-}