aboutsummaryrefslogtreecommitdiff
path: root/MediaBrowser.Common/Net/BasePeriodicWebSocketListener.cs
diff options
context:
space:
mode:
authorTim Hobbs <jesus.tesh@gmail.com>2014-03-24 09:37:44 -0700
committerTim Hobbs <jesus.tesh@gmail.com>2014-03-24 09:37:44 -0700
commit38a0af6e86d3bdf8794343b03d26659d4bf89093 (patch)
treef3c92b89ae3e8a7e744ee13eb1b16139da690622 /MediaBrowser.Common/Net/BasePeriodicWebSocketListener.cs
parent543ce24c1051d10b32c0dae5277ee37c27daceae (diff)
parent501dedb13cd59dc2683ac4192cd11289bd304cfb (diff)
Merge remote-tracking branch 'upstream/master'
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();
}