aboutsummaryrefslogtreecommitdiff
path: root/Jellyfin.Api/Helpers/ProgressiveFileStream.cs
diff options
context:
space:
mode:
authorPatrick Barron <barronpm@gmail.com>2023-10-31 13:26:37 -0400
committerPatrick Barron <barronpm@gmail.com>2023-12-21 12:53:50 -0500
commit9215a4d40ae24e5996a5e16dfa296b09a7befc40 (patch)
tree9412154b3cf4f7a654a8878d23d2f7a3a1d18b5f /Jellyfin.Api/Helpers/ProgressiveFileStream.cs
parentc2081955c8b2a81eb214f321697d3462709164e0 (diff)
Add ITranscodeManager service
Diffstat (limited to 'Jellyfin.Api/Helpers/ProgressiveFileStream.cs')
-rw-r--r--Jellyfin.Api/Helpers/ProgressiveFileStream.cs12
1 files changed, 6 insertions, 6 deletions
diff --git a/Jellyfin.Api/Helpers/ProgressiveFileStream.cs b/Jellyfin.Api/Helpers/ProgressiveFileStream.cs
index 18088483d..98ea844a9 100644
--- a/Jellyfin.Api/Helpers/ProgressiveFileStream.cs
+++ b/Jellyfin.Api/Helpers/ProgressiveFileStream.cs
@@ -15,7 +15,7 @@ public class ProgressiveFileStream : Stream
{
private readonly Stream _stream;
private readonly TranscodingJob? _job;
- private readonly TranscodingJobHelper? _transcodingJobHelper;
+ private readonly ITranscodeManager? _transcodeManager;
private readonly int _timeoutMs;
private bool _disposed;
@@ -24,12 +24,12 @@ public class ProgressiveFileStream : Stream
/// </summary>
/// <param name="filePath">The path to the transcoded file.</param>
/// <param name="job">The transcoding job information.</param>
- /// <param name="transcodingJobHelper">The transcoding job helper.</param>
+ /// <param name="transcodeManager">The transcode manager.</param>
/// <param name="timeoutMs">The timeout duration in milliseconds.</param>
- public ProgressiveFileStream(string filePath, TranscodingJob? job, TranscodingJobHelper transcodingJobHelper, int timeoutMs = 30000)
+ public ProgressiveFileStream(string filePath, TranscodingJob? job, ITranscodeManager transcodeManager, int timeoutMs = 30000)
{
_job = job;
- _transcodingJobHelper = transcodingJobHelper;
+ _transcodeManager = transcodeManager;
_timeoutMs = timeoutMs;
_stream = new FileStream(filePath, FileMode.Open, FileAccess.Read, FileShare.ReadWrite, IODefaults.FileStreamBufferSize, FileOptions.Asynchronous | FileOptions.SequentialScan);
@@ -43,7 +43,7 @@ public class ProgressiveFileStream : Stream
public ProgressiveFileStream(Stream stream, int timeoutMs = 30000)
{
_job = null;
- _transcodingJobHelper = null;
+ _transcodeManager = null;
_timeoutMs = timeoutMs;
_stream = stream;
}
@@ -153,7 +153,7 @@ public class ProgressiveFileStream : Stream
if (_job is not null)
{
- _transcodingJobHelper?.OnTranscodeEndRequest(_job);
+ _transcodeManager?.OnTranscodeEndRequest(_job);
}
}
}