aboutsummaryrefslogtreecommitdiff
path: root/MediaBrowser.Common/Net/BasePeriodicWebSocketListener.cs
diff options
context:
space:
mode:
authortikuf <admin@nyalindee.com>2014-03-25 16:09:30 +1100
committertikuf <admin@nyalindee.com>2014-03-25 16:09:30 +1100
commit520b77a098a5f3755c098636821a7ff3742a055f (patch)
treeb347c31d1333520350422c3e3a08cea292fc8093 /MediaBrowser.Common/Net/BasePeriodicWebSocketListener.cs
parent72bd678b9736ed0cdd8afea90e7e0c91c5b9b4c9 (diff)
parenta94a98dc6c1381c177a407139769e0cad566346b (diff)
Merge branch 'master' of https://github.com/MediaBrowser/MediaBrowser
Diffstat (limited to 'MediaBrowser.Common/Net/BasePeriodicWebSocketListener.cs')
-rw-r--r--MediaBrowser.Common/Net/BasePeriodicWebSocketListener.cs18
1 files changed, 11 insertions, 7 deletions
diff --git a/MediaBrowser.Common/Net/BasePeriodicWebSocketListener.cs b/MediaBrowser.Common/Net/BasePeriodicWebSocketListener.cs
index 4ff34cfa1..33d3f368b 100644
--- a/MediaBrowser.Common/Net/BasePeriodicWebSocketListener.cs
+++ b/MediaBrowser.Common/Net/BasePeriodicWebSocketListener.cs
@@ -1,11 +1,11 @@
-using System.Globalization;
-using MediaBrowser.Model.Logging;
+using MediaBrowser.Model.Logging;
+using MediaBrowser.Model.Net;
using System;
using System.Collections.Generic;
+using System.Globalization;
using System.Linq;
using System.Threading;
using System.Threading.Tasks;
-using MediaBrowser.Model.Net;
namespace MediaBrowser.Common.Net
{
@@ -16,6 +16,7 @@ namespace MediaBrowser.Common.Net
/// <typeparam name="TStateType">The type of the T state type.</typeparam>
public abstract class BasePeriodicWebSocketListener<TReturnDataType, TStateType> : IWebSocketListener, IDisposable
where TStateType : class, new()
+ where TReturnDataType : class
{
/// <summary>
/// The _active connections
@@ -144,12 +145,15 @@ namespace MediaBrowser.Common.Net
var data = await GetDataToSend(tuple.Item4).ConfigureAwait(false);
- await connection.SendAsync(new WebSocketMessage<TReturnDataType>
+ if (data != null)
{
- MessageType = Name,
- Data = data
+ await connection.SendAsync(new WebSocketMessage<TReturnDataType>
+ {
+ MessageType = Name,
+ Data = data
- }, tuple.Item2.Token).ConfigureAwait(false);
+ }, tuple.Item2.Token).ConfigureAwait(false);
+ }
tuple.Item5.Release();
}