zebra_scan/service/scan_task/
tests.rs

1//! Tests for the scan task.
2
3use std::sync::Arc;
4
5use super::{ScanTask, ScanTaskCommand, SCAN_TASK_BUFFER_SIZE};
6
7#[cfg(test)]
8mod vectors;
9
10impl ScanTask {
11    /// Spawns a new [`ScanTask`] for tests.
12    pub fn mock() -> (Self, tokio::sync::mpsc::Receiver<ScanTaskCommand>) {
13        let (cmd_sender, cmd_receiver) = tokio::sync::mpsc::channel(SCAN_TASK_BUFFER_SIZE);
14
15        (
16            Self {
17                handle: Arc::new(tokio::spawn(std::future::pending())),
18                cmd_sender,
19            },
20            cmd_receiver,
21        )
22    }
23}