isagalaev/debounce - Change B733EI5UDUCPJOU6F4X4SYQ3SSYVLPWZK5BVQ5QL56NTAPBY2AGQC

Use channels to test threaded debouncers

Created by isagalaev on October 20, 2021

B733EI5UDUCPJOU6F4X4SYQ3SSYVLPWZK5BVQ5QL56NTAPBY2AGQC

Dependencies

In channels

main

Change contents

Insertion in src/thread.rs at line 75 [3.34]
[2.44]
[2.44]
```
    use std::sync::mpsc::channel;
```

Replacement in src/thread.rs at line 79 [3.34]

B:BD[2.84] → [2.84:323]

        let result = Arc::new(Mutex::new(vec![]));
        let result_clone = Arc::clone(&result);
        let debouncer = EventDebouncer::new(Duration::from_millis(10), move |s: String| {
            result_clone.lock().unwrap().push(s);

[2.84]

[2.323]

        let (tx, rx) = channel();
        let debouncer = EventDebouncer::new(Duration::from_millis(10), move |s| {
            tx.send(s).unwrap();

Replacement in src/thread.rs at line 86 [3.34]

B:BD[2.475] → [2.475:554]

        assert_eq!(result.lock().unwrap().as_slice(), [String::from("Test")]);

[2.475]

[2.554]

        assert!(rx.try_iter().eq([String::from("Test")]));

Replacement in src/thread.rs at line 91 [3.34]

B:BD[2.606] → [2.606:823]

        let result = Arc::new(Mutex::new(vec![]));
        let result_clone = Arc::clone(&result);
        let debouncer = MixedEventDebouncer::new(move |s: String| {
            result_clone.lock().unwrap().push(s);

[2.606]

[2.823]

        let (tx, rx) = channel();
        let debouncer = MixedEventDebouncer::new(move |s| {
            tx.send(s).unwrap();

Replacement in src/thread.rs at line 98 [3.34]

B:BD[2.1029] → [2.1029:1108]

        assert_eq!(result.lock().unwrap().as_slice(), [String::from("Test")]);

[2.1029]

[2.1108]

        assert!(rx.try_iter().eq([String::from("Test")]));