diff --git a/src/ingest.rs b/src/ingest.rs index 2ccb326..8c548e8 100644 --- a/src/ingest.rs +++ b/src/ingest.rs @@ -30,7 +30,7 @@ pub(crate) struct Session { async fn process_ingest( state: &State, - stream: impl Stream> + 'static, + stream: impl Stream>, ) -> Result< ( InternalFormat, @@ -108,7 +108,7 @@ where async fn dummy_ingest( state: &State, - stream: impl Stream> + 'static, + stream: impl Stream>, ) -> Result< ( InternalFormat, @@ -150,7 +150,7 @@ where #[tracing::instrument(skip(state, stream))] pub(crate) async fn ingest( state: &State, - stream: impl Stream> + 'static, + stream: impl Stream>, declared_alias: Option, ) -> Result where diff --git a/src/lib.rs b/src/lib.rs index 038d575..70b1359 100644 --- a/src/lib.rs +++ b/src/lib.rs @@ -460,7 +460,7 @@ struct UrlQuery { } async fn ingest_inline( - stream: impl Stream> + 'static, + stream: impl Stream>, state: &State, ) -> Result<(Alias, DeleteToken, Details), Error> { let session = ingest::ingest(state, stream, None).await?; @@ -513,7 +513,7 @@ async fn download_stream( #[tracing::instrument(name = "Downloading file inline", skip(stream, state))] async fn do_download_inline( - stream: impl Stream> + 'static, + stream: impl Stream>, state: &State, ) -> Result { metrics::counter!(crate::init_metrics::FILES, "download" => "inline").increment(1);