1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25

use crate::{
    csv_parse_result::{CsvByteRecordWithHash, CsvLeftRightParseResult},
    diff_result::DiffByteRecordsIterator,
};
use crossbeam_channel::{Receiver, Sender};

pub struct CsvHashReceiverStreamComparer {
    receiver: Receiver<CsvLeftRightParseResult<CsvByteRecordWithHash>>,
    sender_csv_records_recycle: Sender<csv::ByteRecord>,
}

impl CsvHashReceiverStreamComparer {
    pub(crate) fn new(
        receiver: Receiver<CsvLeftRightParseResult<CsvByteRecordWithHash>>,
        sender_csv_records_recycle: Sender<csv::ByteRecord>,
    ) -> Self {
        Self {
            receiver,
            sender_csv_records_recycle,
        }
    }
    pub fn recv_hashes_and_compare(self) -> DiffByteRecordsIterator {
        DiffByteRecordsIterator::new(self.receiver, self.sender_csv_records_recycle)
    }
}