pub fn make_batch_queue() -> (IncomingBatchSender, IncomingBatchReceiver) {
    let (sender, reciever) = channel();
    let ids = Arc::new(RwLock::new(HashSet::new()));
    (
        IncomingBatchSender::new(ids.clone(), sender),
        IncomingBatchReceiver::new(ids, reciever),
    )
}
/// This queue keeps track of the batch ids so that components on the edge
/// can filter out duplicates early. However, there is still an opportunity for
/// duplicates to make it into this queue, which is intentional to avoid
/// blocking threads trying to put/get from the queue. Any duplicates
/// introduced by this must be filtered out later.
This queue keeps track of the batch ids so that components on the edge
can filter out duplicates early. However, there is still an opportunity for
duplicates to make it into this queue, which is intentional to avoid
blocking threads trying to put/get from the queue. Any duplicates
introduced by this must be filtered out later.
This queue keeps track of the batch ids so that components on the edge can filter out duplicates early . However there is still an opportunity for duplicates to make it into this queue which is intentional to avoid blocking threads trying to put / get from the queue . Any duplicates introduced by this must be filtered out later .
pub fn make_batch_queue() -> (IncomingBatchSender, IncomingBatchReceiver) {
    let (sender, reciever) = channel();
    let ids = Arc::new(RwLock::new(HashSet::new()));
    (
        IncomingBatchSender::new(ids.clone(), sender),
        IncomingBatchReceiver::new(ids, reciever),
    )
}
pub fn make_batch_queue ( ) -> ( IncomingBatchSender , IncomingBatchReceiver ) { let ( sender , reciever ) = channel ( ) ; let ids = Arc :: new ( RwLock :: new ( HashSet :: new ( ) ) ) ; ( IncomingBatchSender :: new ( ids . clone ( ) , sender ) , IncomingBatchReceiver :: new ( ids , reciever ) , ) }
This queue keeps track of the batch ids so that components on the edge
can filter out duplicates early.
This queue keeps track of the batch ids so that components on the edge can filter out duplicates early .