diff --git a/src/storage.rs b/src/storage.rs index 984eae6..bf1872d 100644 --- a/src/storage.rs +++ b/src/storage.rs @@ -202,7 +202,7 @@ pub mod queue { /// A basic implementation of an in-memory queue of quotes. /// Its contents are *not* persisted across application restarts, so it /// is only suited for testing purposes. - #[derive(Actor)] + #[derive(Actor, Default)] pub struct MemoryQueueStorage { quotes: VecDeque, } @@ -310,8 +310,7 @@ where // TODO: Perhaps we should assert that the new quotes are non-empty? // 4. We enqueue the newly-sourced quotes... - let _ = self - .queue_manager + self.queue_manager .ask(EnqueueQuotes(refreshed_quotes)) .await .map_err(|_| ())?; @@ -336,7 +335,7 @@ mod test { let sample_quotes = ["Test no.1", "Test no.2", "Test no.3"]; - let _ = queue_manager + queue_manager .ask(EnqueueQuotes( sample_quotes.iter().cloned().map(Quote::from).collect(), )) @@ -363,7 +362,7 @@ mod test { let sample_quotes = ["Minie", "Miney", "Moe", "and", "some", "more"]; - let source_manager = MemorySourceManager::spawn(MemorySourceManager::new(&sample_quotes)); + let source_manager = MemorySourceManager::spawn(MemorySourceManager::new(sample_quotes)); let quotes = source_manager .ask(SourceQuotes) @@ -394,7 +393,7 @@ mod test { let sample_quotes = ["Minie", "Miney", "Moe"]; let cycle = { - let source = MemorySourceManager::spawn(MemorySourceManager::new(&sample_quotes)); + let source = MemorySourceManager::spawn(MemorySourceManager::new(sample_quotes)); let queue = MemoryQueueStorage::spawn(MemoryQueueStorage::new()); QuoteCycle::spawn(QuoteCycle::with_thread_rng(source, queue))