From e3708145efd0bbed5d10320ee0a0deff0f38479e Mon Sep 17 00:00:00 2001 From: metamuffin Date: Sun, 25 Jan 2026 01:21:24 +0100 Subject: start moving logic code; less arcing in stream --- stream/src/hls.rs | 5 ++--- stream/src/lib.rs | 6 +++--- stream/src/stream_info.rs | 2 +- 3 files changed, 6 insertions(+), 7 deletions(-) (limited to 'stream') diff --git a/stream/src/hls.rs b/stream/src/hls.rs index 5557e48..b8d04ef 100644 --- a/stream/src/hls.rs +++ b/stream/src/hls.rs @@ -11,11 +11,10 @@ use std::{ fmt::Write, io::{Cursor, Read}, ops::Range, - sync::Arc, }; pub fn hls_multivariant_stream( - info: Arc, + info: &SMediaInfo, container: StreamContainer, ) -> Result> { let (_iinfo, info) = stream_info(&info)?; @@ -48,7 +47,7 @@ pub fn hls_multivariant_stream( } pub fn hls_variant_stream( - info: Arc, + info: &SMediaInfo, track: TrackNum, format: FormatNum, container: StreamContainer, diff --git a/stream/src/lib.rs b/stream/src/lib.rs index 20a5e1c..424e44b 100644 --- a/stream/src/lib.rs +++ b/stream/src/lib.rs @@ -92,13 +92,13 @@ pub fn stream( ) -> Result> { match spec { StreamSpec::Original { track } => original_stream(info, track, range), - StreamSpec::HlsMultiVariant { container } => hls_multivariant_stream(info, container), + StreamSpec::HlsMultiVariant { container } => hls_multivariant_stream(&info, container), StreamSpec::HlsVariant { track, container, format, - } => hls_variant_stream(info, track, format, container), - StreamSpec::Info => write_stream_info(info), + } => hls_variant_stream(&info, track, format, container), + StreamSpec::Info => write_stream_info(&info), StreamSpec::FragmentIndex { track } => fragment_index_stream(info, track), StreamSpec::Fragment { track, diff --git a/stream/src/stream_info.rs b/stream/src/stream_info.rs index 4a2605e..33dd288 100644 --- a/stream/src/stream_info.rs +++ b/stream/src/stream_info.rs @@ -157,7 +157,7 @@ fn containers_by_codec(codec: &str) -> Vec { } } -pub(crate) fn write_stream_info(info: Arc) -> Result> { +pub(crate) fn write_stream_info(info: &SMediaInfo) -> Result> { let (_, info) = stream_info(&info)?; Ok(Box::new(Cursor::new(serde_json::to_vec(&info)?))) } -- cgit v1.3