diff --git a/src/api/model/streams/shared_stream_manager.rs b/src/api/model/streams/shared_stream_manager.rs index f6f4f2166..c80ce66ab 100644 --- a/src/api/model/streams/shared_stream_manager.rs +++ b/src/api/model/streams/shared_stream_manager.rs @@ -44,7 +44,7 @@ where } fn convert_stream(stream: BoxStream) -> BoxStream> { - Box::pin(ReceiverStreamWrapper { stream }.boxed()) + ReceiverStreamWrapper { stream }.boxed() } type SubscriberId = usize; diff --git a/src/model/config.rs b/src/model/config.rs index 26a2a17a0..f8cbe6347 100644 --- a/src/model/config.rs +++ b/src/model/config.rs @@ -645,6 +645,13 @@ impl Config { if let Some(mapping_path) = &self.mapping_path { self.t_mapping_file_path = mapping_path.to_string(); } + + if let Some(mins) = self.sleep_timer_mins { + if mins == 0 { + return Err(TuliproxError::new(TuliproxErrorKind::Info, "`sleep_timer_mins` must be > 0 when specified".to_string())); + } + } + if include_computed { self.t_access_token_secret = generate_secret(); self.t_encrypt_secret = <&[u8] as TryInto<[u8; 16]>>::try_into(&generate_secret()[0..16]).map_err(|err| TuliproxError::new(TuliproxErrorKind::Info, err.to_string()))?;