{"header":{"message":"Generic DebouncerThread","description":null,"timestamp":"2021-10-18T19:39:35.528493887Z","authors":[{}]},"hash":"VXKHXMQLNMD7OG4CKSZTX75WMHYTGXJG7AL7YTQBMI2WJ3GQC6JQC","authors":[{"login":"isagalaev","key":"GGyJA92mZf4oyvR5S2XWq6i2USZKkrxmabqwBcQpBwSe"}],"deps":{"hashes":[["VXKHXMQLNMD7OG4CKSZTX75WMHYTGXJG7AL7YTQBMI2WJ3GQC6JQC","Generic DebouncerThread"],["AA",null],["IOHM3NIST5FMQDSRXXXOBNK2DKQKHDFB4YWJWRB6B2ROWVB7W75QC","Extract threaded debouncers in a module"]],"deps":["IOHM3NIST5FMQDSRXXXOBNK2DKQKHDFB4YWJWRB6B2ROWVB7W75QC"],"known":[]},"hunks":[{"Replacement":{"inode":{"change":2,"pos":34},"path":"src/thread.rs","line":6,"ins":{"up_context":[{"change":2,"pos":189}],"down_context":[{"change":2,"pos":259}],"flag":"BLOCK","start":0,"end":58,"inode":{"change":2,"pos":34}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":189},"to":{"change":2,"start":189,"end":259},"introduced_by":2}],"inode":{"change":2,"pos":34}},"ins_contents":[{"Add":"pub struct DebouncerThread {"},{"Add":" mutex: Arc>,"}],"del_contents":[{"Del":"pub struct EventDebouncer {\n mutex: Arc>>,\n"}]}},{"Replacement":{"inode":{"change":2,"pos":34},"path":"src/thread.rs","line":11,"ins":{"up_context":[{"change":2,"pos":290}],"down_context":[{"change":2,"pos":766}],"flag":"BLOCK","start":59,"end":710,"inode":{"change":2,"pos":34}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":290},"to":{"change":2,"start":290,"end":766},"introduced_by":2}],"inode":{"change":2,"pos":34}},"ins_contents":[{"Add":"impl DebouncerThread {"},{"Add":" fn new(buffer: B, f: F) -> Self"},{"Add":" where"},{"Add":" B: BufferGet + Send + 'static,"},{"Add":" F: Fn(T) -> () + Send + 'static,"},{"Add":" T: Send + 'static,"},{"Add":" {"},{"Add":" let mutex = Arc::new(Mutex::new(buffer));"},{"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":" }"}],"del_contents":[{"Del":"fn spawn(mutex: &Arc>, f: F) -> JoinHandle<()>\nwhere\n B: BufferGet + Send + 'static,\n F: Fn(T) -> () + Send + 'static,\n T: Send + 'static,\n{\n let mutex = mutex.clone();\n thread::spawn(move || loop {\n let state = { mutex.lock().unwrap().get() };\n match state {\n State::Empty => thread::park(),\n State::Wait(duration) => thread::sleep(duration),\n State::Ready(data) => f(data),\n }\n })\n"}]}},{"Edit":{"inode":{"change":2,"pos":34},"path":"src/thread.rs","line":32,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":769}],"down_context":[{"change":2,"pos":769}],"flag":"BLOCK","start":711,"end":775,"inode":{"change":2,"pos":34}}},"contents":[{"Add":"pub struct EventDebouncer(DebouncerThread>);"},{"Add":""}]}},{"Replacement":{"inode":{"change":2,"pos":34},"path":"src/thread.rs","line":40,"ins":{"up_context":[{"change":2,"pos":941}],"down_context":[{"change":2,"pos":1078}],"flag":"BLOCK","start":776,"end":839,"inode":{"change":2,"pos":34}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":941},"to":{"change":2,"start":941,"end":1078},"introduced_by":2}],"inode":{"change":2,"pos":34}},"ins_contents":[{"Add":" Self(DebouncerThread::new(EventBuffer::new(delay), f))"}],"del_contents":[{"Del":" let mutex = Arc::new(Mutex::new(EventBuffer::new(delay)));\n let thread = spawn(&mutex, f);\n Self { mutex, thread }\n"}]}},{"Replacement":{"inode":{"change":2,"pos":34},"path":"src/thread.rs","line":44,"ins":{"up_context":[{"change":2,"pos":1118}],"down_context":[{"change":2,"pos":1203}],"flag":"BLOCK","start":840,"end":929,"inode":{"change":2,"pos":34}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":1118},"to":{"change":2,"start":1118,"end":1203},"introduced_by":2}],"inode":{"change":2,"pos":34}},"ins_contents":[{"Add":" self.0.mutex.lock().unwrap().put(data);"},{"Add":" self.0.thread.thread().unpark();"}],"del_contents":[{"Del":" self.mutex.lock().unwrap().put(data);\n self.thread.thread().unpark();\n"}]}},{"Replacement":{"inode":{"change":2,"pos":34},"path":"src/thread.rs","line":49,"ins":{"up_context":[{"change":2,"pos":1212}],"down_context":[{"change":2,"pos":1322}],"flag":"BLOCK","start":930,"end":1003,"inode":{"change":2,"pos":34}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":1212},"to":{"change":2,"start":1212,"end":1322},"introduced_by":2}],"inode":{"change":2,"pos":34}},"ins_contents":[{"Add":"pub struct MixedEventDebouncer(DebouncerThread>);"}],"del_contents":[{"Del":"pub struct MixedEventDebouncer {\n mutex: Arc>>,\n thread: JoinHandle<()>,\n}\n"}]}},{"Replacement":{"inode":{"change":2,"pos":34},"path":"src/thread.rs","line":57,"ins":{"up_context":[{"change":2,"pos":1476}],"down_context":[{"change":2,"pos":1613}],"flag":"BLOCK","start":1004,"end":1067,"inode":{"change":2,"pos":34}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":1476},"to":{"change":2,"start":1476,"end":1613},"introduced_by":2}],"inode":{"change":2,"pos":34}},"ins_contents":[{"Add":" Self(DebouncerThread::new(MixedEventBuffer::new(), f))"}],"del_contents":[{"Del":" let mutex = Arc::new(Mutex::new(MixedEventBuffer::new()));\n let thread = spawn(&mutex, f);\n Self { mutex, thread }\n"}]}},{"Replacement":{"inode":{"change":2,"pos":34},"path":"src/thread.rs","line":61,"ins":{"up_context":[{"change":2,"pos":1670}],"down_context":[{"change":2,"pos":1762}],"flag":"BLOCK","start":1068,"end":1164,"inode":{"change":2,"pos":34}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":1670},"to":{"change":2,"start":1670,"end":1762},"introduced_by":2}],"inode":{"change":2,"pos":34}},"ins_contents":[{"Add":" self.0.mutex.lock().unwrap().put(data, delay);"},{"Add":" self.0.thread.thread().unpark();"}],"del_contents":[{"Del":" self.mutex.lock().unwrap().put(data, delay);\n self.thread.thread().unpark();\n"}]}}],"owner":"isagalaev","repo":"debounce","token":"58fSA1dz4rjstf5G61qeggjLgR/ReXjEsoX7INyNgYQ=","login":null}

…

Dependencies

Change contents