aboutsummaryrefslogtreecommitdiff
path: root/MediaBrowser.Controller/LiveTv
diff options
context:
space:
mode:
authorLuke Pulverenti <luke.pulverenti@gmail.com>2016-10-10 14:18:28 -0400
committerLuke Pulverenti <luke.pulverenti@gmail.com>2016-10-10 14:18:28 -0400
commitcb26cb94579b772fa7825c6769dc7ace38217168 (patch)
treea59864414d58bd01c86085a36355fc553dd43736 /MediaBrowser.Controller/LiveTv
parentdaaae69df575f1d7692ba29d6f5ddd4c59516f82 (diff)
update program queries
Diffstat (limited to 'MediaBrowser.Controller/LiveTv')
-rw-r--r--MediaBrowser.Controller/LiveTv/LiveStream.cs15
1 files changed, 8 insertions, 7 deletions
diff --git a/MediaBrowser.Controller/LiveTv/LiveStream.cs b/MediaBrowser.Controller/LiveTv/LiveStream.cs
index a5d432a54f..0908c3eccb 100644
--- a/MediaBrowser.Controller/LiveTv/LiveStream.cs
+++ b/MediaBrowser.Controller/LiveTv/LiveStream.cs
@@ -1,4 +1,5 @@
using System;
+using System.Collections.Generic;
using System.Threading;
using System.Threading.Tasks;
using MediaBrowser.Model.Dto;
@@ -9,13 +10,16 @@ namespace MediaBrowser.Controller.LiveTv
{
public MediaSourceInfo OriginalMediaSource { get; set; }
public MediaSourceInfo OpenedMediaSource { get; set; }
- public DateTime DateOpened { get; set; }
- public int ConsumerCount { get; set; }
+ public int ConsumerCount {
+ get { return SharedStreamIds.Count; }
+ }
public ITunerHost TunerHost { get; set; }
public string OriginalStreamId { get; set; }
public bool EnableStreamSharing { get; set; }
public string UniqueId = Guid.NewGuid().ToString("N");
+ public List<string> SharedStreamIds = new List<string>();
+
public LiveStream(MediaSourceInfo mediaSource)
{
OriginalMediaSource = mediaSource;
@@ -23,12 +27,9 @@ namespace MediaBrowser.Controller.LiveTv
EnableStreamSharing = true;
}
- public async Task Open(CancellationToken cancellationToken)
+ public Task Open(CancellationToken cancellationToken)
{
- await OpenInternal(cancellationToken).ConfigureAwait(false);
- DateOpened = DateTime.UtcNow;
-
- OpenedMediaSource.DateLiveStreamOpened = DateOpened;
+ return OpenInternal(cancellationToken);
}
protected virtual Task OpenInternal(CancellationToken cancellationToken)