{"header":{"message":"Extract EventDebouncer struct","description":null,"timestamp":"2021-10-18T05:49:02.983167983Z","authors":[{}]},"hash":"JH7KD6PAPVSYSACYT64VV3VPJKKWETXVK4THJH2GJS3MDUAIJ6OQC","authors":[{"login":"isagalaev","key":"GGyJA92mZf4oyvR5S2XWq6i2USZKkrxmabqwBcQpBwSe"}],"deps":{"hashes":[["JH7KD6PAPVSYSACYT64VV3VPJKKWETXVK4THJH2GJS3MDUAIJ6OQC","Extract EventDebouncer struct"],["AA",null],["GHHTX7RJBZIACNMK7GEI7HCWWZTXYQ4E77RHIYC6GDWOCPIDBHJAC","Working draft of debounce CLI tool"]],"deps":["GHHTX7RJBZIACNMK7GEI7HCWWZTXYQ4E77RHIYC6GDWOCPIDBHJAC"],"known":[]},"hunks":[{"Replacement":{"inode":{"change":2,"pos":57},"path":"examples/debounce.rs","line":10,"ins":{"up_context":[{"change":2,"pos":273}],"down_context":[{"change":2,"pos":430}],"flag":"BLOCK","start":0,"end":94,"inode":{"change":2,"pos":57}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":273},"to":{"change":2,"start":273,"end":430},"introduced_by":2}],"inode":{"change":2,"pos":57}},"ins_contents":[{"Add":"struct EventDebouncer {"},{"Add":" mutex: Arc>>,"},{"Add":" thread: JoinHandle<()>,"}],"del_contents":[{"Del":"fn put(mutex: &Mutex>, debouncer: &JoinHandle<()>, data: String) {\n mutex.lock().unwrap().put(data);\n debouncer.thread().unpark();\n"}]}},{"Replacement":{"inode":{"change":2,"pos":57},"path":"examples/debounce.rs","line":15,"ins":{"up_context":[{"change":2,"pos":433}],"down_context":[{"change":2,"pos":527}],"flag":"BLOCK","start":95,"end":869,"inode":{"change":2,"pos":57}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":433},"to":{"change":2,"start":433,"end":527},"introduced_by":2}],"inode":{"change":2,"pos":57}},"ins_contents":[{"Add":"impl EventDebouncer {"},{"Add":" fn new(timeout: Duration, f: F) -> Self"},{"Add":" where"},{"Add":" F: Fn(T) -> (),"},{"Add":" F: Send + 'static,"},{"Add":" T: Send + 'static,"},{"Add":" {"},{"Add":" let mutex = Arc::new(Mutex::new(EventBuffer::new(timeout)));"},{"Add":" let mutex_clone = mutex.clone();"},{"Add":" let thread = thread::spawn(move || loop {"},{"Add":" let state = { mutex_clone.lock().unwrap().get() };"},{"Add":" match state {"},{"Add":" State::Empty => thread::park(),"},{"Add":" State::Wait(duration) => thread::sleep(duration),"},{"Add":" State::Ready(data) => f(data),"},{"Add":" }"},{"Add":" });"},{"Add":" Self { mutex, thread }"},{"Add":" }"},{"Add":""},{"Add":" fn put(&self, data: T) {"},{"Add":" self.mutex.lock().unwrap().put(data);"},{"Add":" self.thread.thread().unpark();"},{"Add":" }"}],"del_contents":[{"Del":"fn get(mutex: &Mutex>) -> State {\n mutex.lock().unwrap().get()\n"}]}},{"Edit":{"inode":{"change":2,"pos":57},"path":"examples/debounce.rs","line":47,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":832},"to":{"change":2,"start":832,"end":992},"introduced_by":2}],"inode":{"change":2,"pos":57}}},"contents":[{"Del":" let mutex = Arc::new(Mutex::new(EventBuffer::new(Duration::from_millis(timeout))));\n let mutex_clone = mutex.clone();\n let mut stdout = io::stdout();\n"}]}},{"Replacement":{"inode":{"change":2,"pos":57},"path":"examples/debounce.rs","line":48,"ins":{"up_context":[{"change":2,"pos":993}],"down_context":[{"change":2,"pos":1298}],"flag":"BLOCK","start":870,"end":1018,"inode":{"change":2,"pos":57}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":993},"to":{"change":2,"start":993,"end":1298},"introduced_by":2}],"inode":{"change":2,"pos":57}},"ins_contents":[{"Add":" let debouncer = EventDebouncer::new(Duration::from_millis(timeout), move |data: String| {"},{"Add":" io::stdout().write_all(data.as_bytes()).ok();"}],"del_contents":[{"Del":" let debouncer = thread::spawn(move || loop {\n match get(&mutex_clone) {\n State::Empty => thread::park(),\n State::Wait(duration) => thread::sleep(duration),\n State::Ready(data) => {\n stdout.write_all(data.as_bytes()).ok();\n }\n }\n"}]}},{"Replacement":{"inode":{"change":2,"pos":57},"path":"examples/debounce.rs","line":56,"ins":{"up_context":[{"change":2,"pos":1430}],"down_context":[{"change":2,"pos":1471}],"flag":"BLOCK","start":1019,"end":1050,"inode":{"change":2,"pos":57}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":1430},"to":{"change":2,"start":1430,"end":1471},"introduced_by":2}],"inode":{"change":2,"pos":57}},"ins_contents":[{"Add":" debouncer.put(buffer);"}],"del_contents":[{"Del":" put(&mutex, &debouncer, buffer);\n"}]}}],"owner":"isagalaev","repo":"debounce","token":"eorwrr5hSoi8gqy/9IbfzmwNtUWQPVPrzzSvSo7Mju8=","login":null}

…

Dependencies

Change contents