From 74acb928996bcade2829c57187f35a31723be700 Mon Sep 17 00:00:00 2001
From: metamuffin <metamuffin@disroot.org>
Date: Mon, 2 Oct 2023 17:54:55 +0200
Subject: spawn_blocking where neccesary

---
 stream/src/hls.rs | 20 +++++++++++++-------
 1 file changed, 13 insertions(+), 7 deletions(-)

(limited to 'stream/src')

diff --git a/stream/src/hls.rs b/stream/src/hls.rs
index c5b7f91..ea82fed 100644
--- a/stream/src/hls.rs
+++ b/stream/src/hls.rs
@@ -11,7 +11,10 @@ use jellycommon::{
     LocalTrack, Node,
 };
 use std::{fmt::Write, ops::Range};
-use tokio::io::{AsyncWriteExt, DuplexStream};
+use tokio::{
+    io::{AsyncWriteExt, DuplexStream},
+    task::spawn_blocking,
+};
 
 pub async fn hls_master_stream(
     _node: Node,
@@ -47,12 +50,15 @@ pub async fn hls_variant_stream(
     mut b: DuplexStream,
 ) -> Result<()> {
     let track = *spec.tracks.get(0).ok_or(anyhow!("no track"))?;
-    let snips = jellyremuxer::snippet::snippet_index(
-        &CONF.library_path,
-        &node.public,
-        &track_sources,
-        track,
-    )?;
+    let snips = spawn_blocking(move || {
+        jellyremuxer::snippet::snippet_index(
+            &CONF.library_path,
+            &node.public,
+            &track_sources,
+            track,
+        )
+    })
+    .await??;
     let mut out = String::new();
     writeln!(out, "#EXTM3U")?;
     writeln!(out, "#EXT-X-VERSION:4")?;
-- 
cgit v1.2.3-70-g09d2