diff --git a/src/agents/audio_agent.rs b/src/agents/audio_agent.rs index 372c609..a12faba 100644 --- a/src/agents/audio_agent.rs +++ b/src/agents/audio_agent.rs @@ -7,6 +7,8 @@ use yew::services::{ConsoleService, ReaderService}; use yew::worker::*; use yewtil::future::LinkFuture; +const FILE_LOAD_CHUNK_SIZE: usize = 4096; + pub struct AudioAgent { link: AgentLink, reader_service: ReaderService, @@ -54,9 +56,7 @@ impl Agent for AudioAgent { fn update(&mut self, msg: Self::Message) { match msg { Msg::FileProgress(Some(FileChunk::DataChunk { data, progress })) => { - if let Err(e) = self.handle_file_progress(data, progress) { - ConsoleService::error(&e); - } + self.handle_file_progress(data, progress) } Msg::FileProgress(Some(FileChunk::Finished)) => { if let Err(e) = self.handle_file_loaded() { @@ -87,7 +87,7 @@ impl AudioAgent { let task = self .reader_service - .read_file_by_chunks(file, cb, 256) + .read_file_by_chunks(file, cb, FILE_LOAD_CHUNK_SIZE) .map_err(|e| e.to_string())?; self.reader_task = Some(task); @@ -95,9 +95,8 @@ impl AudioAgent { Ok(()) } - fn handle_file_progress(&mut self, mut data: Vec, _progress: f32) -> Result<(), String> { + fn handle_file_progress(&mut self, mut data: Vec, _progress: f32) { self.bytes_buffer.append(&mut data); - Ok(()) } fn handle_file_loaded(&self) -> Result<(), String> {