aboutsummaryrefslogtreecommitdiff
path: root/src/Jellyfin.LiveTv/ExclusiveLiveStream.cs
diff options
context:
space:
mode:
Diffstat (limited to 'src/Jellyfin.LiveTv/ExclusiveLiveStream.cs')
-rw-r--r--src/Jellyfin.LiveTv/ExclusiveLiveStream.cs61
1 files changed, 61 insertions, 0 deletions
diff --git a/src/Jellyfin.LiveTv/ExclusiveLiveStream.cs b/src/Jellyfin.LiveTv/ExclusiveLiveStream.cs
new file mode 100644
index 000000000..9d442e20c
--- /dev/null
+++ b/src/Jellyfin.LiveTv/ExclusiveLiveStream.cs
@@ -0,0 +1,61 @@
+#nullable disable
+
+#pragma warning disable CA1711
+#pragma warning disable CS1591
+
+using System;
+using System.Globalization;
+using System.IO;
+using System.Threading;
+using System.Threading.Tasks;
+using MediaBrowser.Controller.Library;
+using MediaBrowser.Model.Dto;
+
+namespace Jellyfin.LiveTv
+{
+ public sealed class ExclusiveLiveStream : ILiveStream
+ {
+ private readonly Func<Task> _closeFn;
+
+ public ExclusiveLiveStream(MediaSourceInfo mediaSource, Func<Task> closeFn)
+ {
+ MediaSource = mediaSource;
+ EnableStreamSharing = false;
+ _closeFn = closeFn;
+ ConsumerCount = 1;
+ UniqueId = Guid.NewGuid().ToString("N", CultureInfo.InvariantCulture);
+ }
+
+ public int ConsumerCount { get; set; }
+
+ public string OriginalStreamId { get; set; }
+
+ public string TunerHostId => null;
+
+ public bool EnableStreamSharing { get; set; }
+
+ public MediaSourceInfo MediaSource { get; set; }
+
+ public string UniqueId { get; }
+
+ public Task Close()
+ {
+ return _closeFn();
+ }
+
+ public Stream GetStream()
+ {
+ throw new NotSupportedException();
+ }
+
+ public Task Open(CancellationToken openCancellationToken)
+ {
+ return Task.CompletedTask;
+ }
+
+ /// <inheritdoc />
+ public void Dispose()
+ {
+ }
+ }
+}