{"header":{"message":"Extract threaded debouncers in a module","description":null,"timestamp":"2021-10-18T06:19:35.553701022Z","authors":[{}]},"hash":"IOHM3NIST5FMQDSRXXXOBNK2DKQKHDFB4YWJWRB6B2ROWVB7W75QC","authors":[{"login":"isagalaev","key":"GGyJA92mZf4oyvR5S2XWq6i2USZKkrxmabqwBcQpBwSe"}],"deps":{"hashes":[["IOHM3NIST5FMQDSRXXXOBNK2DKQKHDFB4YWJWRB6B2ROWVB7W75QC","Extract threaded debouncers in a module"],["AA",null],["JH7KD6PAPVSYSACYT64VV3VPJKKWETXVK4THJH2GJS3MDUAIJ6OQC","Extract EventDebouncer struct"],["U5KNSQ77TIOWPR7H276RHQJMVHC4TWCDGGRM65LQ5VSPPGHUCY7QC","Initial commit"],["GHHTX7RJBZIACNMK7GEI7HCWWZTXYQ4E77RHIYC6GDWOCPIDBHJAC","Working draft of debounce CLI tool"]],"deps":["JH7KD6PAPVSYSACYT64VV3VPJKKWETXVK4THJH2GJS3MDUAIJ6OQC"],"known":["U5KNSQ77TIOWPR7H276RHQJMVHC4TWCDGGRM65LQ5VSPPGHUCY7QC","GHHTX7RJBZIACNMK7GEI7HCWWZTXYQ4E77RHIYC6GDWOCPIDBHJAC"]},"hunks":[{"FileAdd":{"meta":{"basename":"thread.rs","metadata":0},"context":[{"change":3,"pos":15}],"contents":[{"Add":"use crate::{BufferGet, EventBuffer, MixedEventBuffer, State};"},{"Add":"use std::sync::{Arc, Mutex};"},{"Add":"use std::thread::{self, JoinHandle};"},{"Add":"use std::time::Duration;"},{"Add":""},{"Add":"pub struct EventDebouncer {"},{"Add":" mutex: Arc>>,"},{"Add":" thread: JoinHandle<()>,"},{"Add":"}"},{"Add":""},{"Add":"fn spawn(mutex: &Arc>, f: F) -> JoinHandle<()>"},{"Add":"where"},{"Add":" B: BufferGet + Send + 'static,"},{"Add":" F: Fn(T) -> () + Send + 'static,"},{"Add":" T: Send + 'static,"},{"Add":"{"},{"Add":" let mutex = mutex.clone();"},{"Add":" thread::spawn(move || loop {"},{"Add":" let state = { mutex.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":"}"},{"Add":""},{"Add":"impl EventDebouncer {"},{"Add":" pub fn new(delay: Duration, f: F) -> Self"},{"Add":" where"},{"Add":" F: Fn(T) -> () + Send + 'static,"},{"Add":" T: Send + 'static,"},{"Add":" {"},{"Add":" let mutex = Arc::new(Mutex::new(EventBuffer::new(delay)));"},{"Add":" let thread = spawn(&mutex, f);"},{"Add":" Self { mutex, thread }"},{"Add":" }"},{"Add":""},{"Add":" pub fn put(&self, data: T) {"},{"Add":" self.mutex.lock().unwrap().put(data);"},{"Add":" self.thread.thread().unpark();"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"pub struct MixedEventDebouncer {"},{"Add":" mutex: Arc>>,"},{"Add":" thread: JoinHandle<()>,"},{"Add":"}"},{"Add":""},{"Add":"impl MixedEventDebouncer {"},{"Add":" pub fn new(f: F) -> Self"},{"Add":" where"},{"Add":" F: Fn(T) -> () + Send + 'static,"},{"Add":" T: Send + 'static,"},{"Add":" {"},{"Add":" let mutex = Arc::new(Mutex::new(MixedEventBuffer::new()));"},{"Add":" let thread = spawn(&mutex, f);"},{"Add":" Self { mutex, thread }"},{"Add":" }"},{"Add":""},{"Add":" pub fn put(&self, data: T, delay: Duration) {"},{"Add":" self.mutex.lock().unwrap().put(data, delay);"},{"Add":" self.thread.thread().unpark();"},{"Add":" }"},{"Add":"}"}]}},{"Edit":{"inode":{"change":3,"pos":47},"path":"src/lib.rs","line":6,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":187}],"down_context":[{"change":3,"pos":187}],"flag":"BLOCK","start":1771,"end":1788,"inode":{"change":3,"pos":47}}},"contents":[{"Add":""},{"Add":"pub mod thread;"}]}},{"Replacement":{"inode":{"change":3,"pos":47},"path":"src/lib.rs","line":34,"ins":{"up_context":[{"change":3,"pos":680}],"down_context":[{"change":3,"pos":740}],"flag":"BLOCK","start":1789,"end":1845,"inode":{"change":3,"pos":47}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":680},"to":{"change":3,"start":680,"end":740},"introduced_by":3}],"inode":{"change":3,"pos":47}},"ins_contents":[{"Add":"trait BufferGet {"},{"Add":" fn get(&mut self) -> State;"}],"del_contents":[{"Del":"pub struct Debouncer {\n events: BinaryHeap>,\n"}]}},{"Replacement":{"inode":{"change":3,"pos":47},"path":"src/lib.rs","line":38,"ins":{"up_context":[{"change":3,"pos":743}],"down_context":[{"change":3,"pos":864}],"flag":"BLOCK","start":1846,"end":2096,"inode":{"change":3,"pos":47}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":743},"to":{"change":3,"start":743,"end":864},"introduced_by":3}],"inode":{"change":3,"pos":47}},"ins_contents":[{"Add":"pub struct EventBuffer {"},{"Add":" delay: Duration,"},{"Add":" events: VecDeque>,"},{"Add":"}"},{"Add":""},{"Add":"impl EventBuffer {"},{"Add":" pub fn new(delay: Duration) -> EventBuffer {"},{"Add":" EventBuffer {"},{"Add":" delay,"},{"Add":" events: VecDeque::new(),"}],"del_contents":[{"Del":"impl Debouncer {\n pub fn new() -> Debouncer {\n Debouncer {\n events: BinaryHeap::new(),\n"}]}},{"Replacement":{"inode":{"change":3,"pos":47},"path":"src/lib.rs","line":51,"ins":{"up_context":[{"change":3,"pos":881}],"down_context":[{"change":3,"pos":935}],"flag":"BLOCK","start":2097,"end":2134,"inode":{"change":3,"pos":47}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":881},"to":{"change":3,"start":881,"end":935},"introduced_by":3}],"inode":{"change":3,"pos":47}},"ins_contents":[{"Add":" pub fn put(&mut self, item: T) {"}],"del_contents":[{"Del":" pub fn put(&mut self, item: T, delay: Duration) {\n"}]}},{"Replacement":{"inode":{"change":3,"pos":47},"path":"src/lib.rs","line":55,"ins":{"up_context":[{"change":3,"pos":1055}],"down_context":[{"change":3,"pos":1088}],"flag":"BLOCK","start":2135,"end":2173,"inode":{"change":3,"pos":47}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":1055},"to":{"change":3,"start":1055,"end":1088},"introduced_by":3}],"inode":{"change":3,"pos":47}},"ins_contents":[{"Add":" self.events.push_back(Event {"}],"del_contents":[{"Del":" self.events.push(Event {\n"}]}},{"Replacement":{"inode":{"change":3,"pos":47},"path":"src/lib.rs","line":57,"ins":{"up_context":[{"change":3,"pos":1106}],"down_context":[{"change":3,"pos":1144}],"flag":"BLOCK","start":2174,"end":2217,"inode":{"change":3,"pos":47}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":1106},"to":{"change":3,"start":1106,"end":1144},"introduced_by":3}],"inode":{"change":3,"pos":47}},"ins_contents":[{"Add":" release_at: time + self.delay,"}],"del_contents":[{"Del":" release_at: time + delay,\n"}]}},{"Edit":{"inode":{"change":3,"pos":47},"path":"src/lib.rs","line":60,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":1162}],"down_context":[{"change":3,"pos":1162}],"flag":"BLOCK","start":2218,"end":2220,"inode":{"change":3,"pos":47}}},"contents":[{"Add":"}"}]}},{"Replacement":{"inode":{"change":3,"pos":47},"path":"src/lib.rs","line":62,"ins":{"up_context":[{"change":3,"pos":1163}],"down_context":[{"change":3,"pos":1203}],"flag":"BLOCK","start":2221,"end":2299,"inode":{"change":3,"pos":47}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":1163},"to":{"change":3,"start":1163,"end":1203},"introduced_by":3}],"inode":{"change":3,"pos":47}},"ins_contents":[{"Add":"impl BufferGet for EventBuffer {"},{"Add":" fn get(&mut self) -> State {"}],"del_contents":[{"Del":" pub fn get(&mut self) -> State {\n"}]}},{"Replacement":{"inode":{"change":3,"pos":47},"path":"src/lib.rs","line":65,"ins":{"up_context":[{"change":3,"pos":1238}],"down_context":[{"change":3,"pos":1273}],"flag":"BLOCK","start":2300,"end":2335,"inode":{"change":3,"pos":47}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":1238},"to":{"change":3,"start":1238,"end":1273},"introduced_by":3}],"inode":{"change":3,"pos":47}},"ins_contents":[{"Add":" match self.events.get(0) {"}],"del_contents":[{"Del":" match self.events.peek() {\n"}]}},{"Replacement":{"inode":{"change":3,"pos":47},"path":"src/lib.rs","line":68,"ins":{"up_context":[{"change":3,"pos":1387}],"down_context":[{"change":3,"pos":1457}],"flag":"BLOCK","start":2336,"end":2412,"inode":{"change":3,"pos":47}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":1387},"to":{"change":3,"start":1387,"end":1457},"introduced_by":3}],"inode":{"change":3,"pos":47}},"ins_contents":[{"Add":" Some(_) => State::Ready(self.events.pop_front().unwrap().item),"}],"del_contents":[{"Del":" Some(_) => State::Ready(self.events.pop().unwrap().item),\n"}]}},{"Replacement":{"inode":{"change":3,"pos":47},"path":"src/lib.rs","line":73,"ins":{"up_context":[{"change":3,"pos":1476}],"down_context":[{"change":3,"pos":1562}],"flag":"BLOCK","start":2413,"end":2480,"inode":{"change":3,"pos":47}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":1476},"to":{"change":3,"start":1476,"end":1562},"introduced_by":3}],"inode":{"change":3,"pos":47}},"ins_contents":[{"Add":"pub struct MixedEventBuffer {"},{"Add":" events: BinaryHeap>,"}],"del_contents":[{"Del":"pub struct UniformDebouncer {\n delay: Duration,\n events: VecDeque>,\n"}]}},{"Replacement":{"inode":{"change":3,"pos":47},"path":"src/lib.rs","line":77,"ins":{"up_context":[{"change":3,"pos":1565}],"down_context":[{"change":3,"pos":1746}],"flag":"BLOCK","start":2481,"end":2623,"inode":{"change":3,"pos":47}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":1565},"to":{"change":3,"start":1565,"end":1746},"introduced_by":3}],"inode":{"change":3,"pos":47}},"ins_contents":[{"Add":"impl MixedEventBuffer {"},{"Add":" pub fn new() -> MixedEventBuffer {"},{"Add":" MixedEventBuffer {"},{"Add":" events: BinaryHeap::new(),"}],"del_contents":[{"Del":"impl UniformDebouncer {\n pub fn new(delay: Duration) -> UniformDebouncer {\n UniformDebouncer {\n delay,\n events: VecDeque::new(),\n"}]}},{"Replacement":{"inode":{"change":3,"pos":47},"path":"src/lib.rs","line":84,"ins":{"up_context":[{"change":3,"pos":1763}],"down_context":[{"change":3,"pos":1800}],"flag":"BLOCK","start":2624,"end":2678,"inode":{"change":3,"pos":47}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":1763},"to":{"change":3,"start":1763,"end":1800},"introduced_by":3}],"inode":{"change":3,"pos":47}},"ins_contents":[{"Add":" pub fn put(&mut self, item: T, delay: Duration) {"}],"del_contents":[{"Del":" pub fn put(&mut self, item: T) {\n"}]}},{"Replacement":{"inode":{"change":3,"pos":47},"path":"src/lib.rs","line":88,"ins":{"up_context":[{"change":3,"pos":1920}],"down_context":[{"change":3,"pos":1958}],"flag":"BLOCK","start":2679,"end":2712,"inode":{"change":3,"pos":47}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":1920},"to":{"change":3,"start":1920,"end":1958},"introduced_by":3}],"inode":{"change":3,"pos":47}},"ins_contents":[{"Add":" self.events.push(Event {"}],"del_contents":[{"Del":" self.events.push_back(Event {\n"}]}},{"Replacement":{"inode":{"change":3,"pos":47},"path":"src/lib.rs","line":90,"ins":{"up_context":[{"change":3,"pos":1976}],"down_context":[{"change":3,"pos":2019}],"flag":"BLOCK","start":2713,"end":2751,"inode":{"change":3,"pos":47}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":1976},"to":{"change":3,"start":1976,"end":2019},"introduced_by":3}],"inode":{"change":3,"pos":47}},"ins_contents":[{"Add":" release_at: time + delay,"}],"del_contents":[{"Del":" release_at: time + self.delay,\n"}]}},{"Edit":{"inode":{"change":3,"pos":47},"path":"src/lib.rs","line":93,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":2037}],"down_context":[{"change":3,"pos":2037}],"flag":"BLOCK","start":2752,"end":2754,"inode":{"change":3,"pos":47}}},"contents":[{"Add":"}"}]}},{"Replacement":{"inode":{"change":3,"pos":47},"path":"src/lib.rs","line":95,"ins":{"up_context":[{"change":3,"pos":2038}],"down_context":[{"change":3,"pos":2078}],"flag":"BLOCK","start":2755,"end":2842,"inode":{"change":3,"pos":47}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":2038},"to":{"change":3,"start":2038,"end":2078},"introduced_by":3}],"inode":{"change":3,"pos":47}},"ins_contents":[{"Add":"impl BufferGet for MixedEventBuffer {"},{"Add":" fn get(&mut self) -> State {"}],"del_contents":[{"Del":" pub fn get(&mut self) -> State {\n"}]}},{"Replacement":{"inode":{"change":3,"pos":47},"path":"src/lib.rs","line":98,"ins":{"up_context":[{"change":3,"pos":2113}],"down_context":[{"change":3,"pos":2148}],"flag":"BLOCK","start":2843,"end":2878,"inode":{"change":3,"pos":47}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":2113},"to":{"change":3,"start":2113,"end":2148},"introduced_by":3}],"inode":{"change":3,"pos":47}},"ins_contents":[{"Add":" match self.events.peek() {"}],"del_contents":[{"Del":" match self.events.get(0) {\n"}]}},{"Replacement":{"inode":{"change":3,"pos":47},"path":"src/lib.rs","line":101,"ins":{"up_context":[{"change":3,"pos":2262}],"down_context":[{"change":3,"pos":2338}],"flag":"BLOCK","start":2879,"end":2949,"inode":{"change":3,"pos":47}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":2262},"to":{"change":3,"start":2262,"end":2338},"introduced_by":3}],"inode":{"change":3,"pos":47}},"ins_contents":[{"Add":" Some(_) => State::Ready(self.events.pop().unwrap().item),"}],"del_contents":[{"Del":" Some(_) => State::Ready(self.events.pop_front().unwrap().item),\n"}]}},{"Replacement":{"inode":{"change":3,"pos":47},"path":"src/lib.rs","line":117,"ins":{"up_context":[{"change":3,"pos":2537}],"down_context":[{"change":3,"pos":2587}],"flag":"BLOCK","start":2950,"end":3007,"inode":{"change":3,"pos":47}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":2537},"to":{"change":3,"start":2537,"end":2587},"introduced_by":3}],"inode":{"change":3,"pos":47}},"ins_contents":[{"Add":" let mut debouncer = MixedEventBuffer::new();"}],"del_contents":[{"Del":" let mut debouncer = Debouncer::new();\n"}]}},{"Replacement":{"inode":{"change":3,"pos":47},"path":"src/lib.rs","line":128,"ins":{"up_context":[{"change":3,"pos":2985}],"down_context":[{"change":3,"pos":3035}],"flag":"BLOCK","start":3008,"end":3065,"inode":{"change":3,"pos":47}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":2985},"to":{"change":3,"start":2985,"end":3035},"introduced_by":3}],"inode":{"change":3,"pos":47}},"ins_contents":[{"Add":" let mut debouncer = MixedEventBuffer::new();"}],"del_contents":[{"Del":" let mut debouncer = Debouncer::new();\n"}]}},{"Replacement":{"inode":{"change":3,"pos":47},"path":"src/lib.rs","line":142,"ins":{"up_context":[{"change":3,"pos":3533}],"down_context":[{"change":3,"pos":3583}],"flag":"BLOCK","start":3066,"end":3123,"inode":{"change":3,"pos":47}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":3533},"to":{"change":3,"start":3533,"end":3583},"introduced_by":3}],"inode":{"change":3,"pos":47}},"ins_contents":[{"Add":" let mut debouncer = MixedEventBuffer::new();"}],"del_contents":[{"Del":" let mut debouncer = Debouncer::new();\n"}]}},{"Replacement":{"inode":{"change":3,"pos":47},"path":"src/lib.rs","line":158,"ins":{"up_context":[{"change":3,"pos":3997}],"down_context":[{"change":3,"pos":4079}],"flag":"BLOCK","start":3124,"end":3201,"inode":{"change":3,"pos":47}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":3997},"to":{"change":3,"start":3997,"end":4079},"introduced_by":3}],"inode":{"change":3,"pos":47}},"ins_contents":[{"Add":" let mut debouncer = EventBuffer::new(Duration::from_millis(20));"}],"del_contents":[{"Del":" let mut debouncer = UniformDebouncer::new(Duration::from_millis(20));\n"}]}},{"Replacement":{"inode":{"change":3,"pos":47},"path":"src/lib.rs","line":169,"ins":{"up_context":[{"change":3,"pos":4450}],"down_context":[{"change":3,"pos":4532}],"flag":"BLOCK","start":3202,"end":3279,"inode":{"change":3,"pos":47}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":4450},"to":{"change":3,"start":4450,"end":4532},"introduced_by":3}],"inode":{"change":3,"pos":47}},"ins_contents":[{"Add":" let mut debouncer = EventBuffer::new(Duration::from_millis(20));"}],"del_contents":[{"Del":" let mut debouncer = UniformDebouncer::new(Duration::from_millis(20));\n"}]}},{"Replacement":{"inode":{"change":3,"pos":57},"path":"examples/debounce.rs","line":1,"ins":{"up_context":[{"change":3,"pos":57}],"down_context":[{"change":3,"pos":94}],"flag":"BLOCK","start":3280,"end":3318,"inode":{"change":3,"pos":57}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":57},"to":{"change":3,"start":58,"end":94},"introduced_by":3}],"inode":{"change":3,"pos":57}},"ins_contents":[{"Add":"use debounce::thread::EventDebouncer;"}],"del_contents":[{"Del":"use debounce::{EventBuffer, State};\n"}]}},{"Edit":{"inode":{"change":3,"pos":57},"path":"examples/debounce.rs","line":6,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":181},"to":{"change":3,"start":181,"end":247},"introduced_by":3}],"inode":{"change":3,"pos":57}}},"contents":[{"Del":"use std::sync::{Arc, Mutex};\nuse std::thread::{self, JoinHandle};\n"}]}},{"Edit":{"inode":{"change":3,"pos":57},"path":"examples/debounce.rs","line":7,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":272},"to":{"change":3,"start":272,"end":273},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":273},"to":{"change":2,"start":0,"end":94},"introduced_by":2},{"previous":"","flag":"DELETED","from":{"change":2,"pos":94},"to":{"change":3,"start":430,"end":432},"introduced_by":2},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":430},"to":{"change":3,"start":430,"end":432},"introduced_by":3}],"inode":{"change":3,"pos":57}}},"contents":[{"Del":"\n"},{"Del":"struct EventDebouncer {\n mutex: Arc>>,\n thread: JoinHandle<()>,\n"},{"Del":"}\n"}]}},{"Edit":{"inode":{"change":3,"pos":57},"path":"examples/debounce.rs","line":8,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":433},"to":{"change":2,"start":95,"end":869},"introduced_by":2},{"previous":"","flag":"DELETED","from":{"change":2,"pos":869},"to":{"change":3,"start":527,"end":530},"introduced_by":2},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":527},"to":{"change":3,"start":527,"end":530},"introduced_by":3}],"inode":{"change":3,"pos":57}}},"contents":[{"Del":"impl EventDebouncer {\n fn new(timeout: Duration, f: F) -> Self\n where\n F: Fn(T) -> (),\n F: Send + 'static,\n T: Send + 'static,\n {\n let mutex = Arc::new(Mutex::new(EventBuffer::new(timeout)));\n let mutex_clone = mutex.clone();\n let thread = thread::spawn(move || loop {\n let state = { mutex_clone.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 Self { mutex, thread }\n }\n\n fn put(&self, data: T) {\n self.mutex.lock().unwrap().put(data);\n self.thread.thread().unpark();\n }\n"},{"Del":"}\n\n"}]}},{"Edit":{"inode":{"change":3,"pos":57},"path":"examples/debounce.rs","line":9,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":572}],"down_context":[{"change":3,"pos":572}],"flag":"BLOCK","start":3319,"end":3342,"inode":{"change":3,"pos":57}}},"contents":[{"Add":" // Parse arguments"}]}},{"Replacement":{"inode":{"change":3,"pos":57},"path":"examples/debounce.rs","line":12,"ins":{"up_context":[{"change":3,"pos":658}],"down_context":[{"change":3,"pos":731}],"flag":"BLOCK","start":3343,"end":3414,"inode":{"change":3,"pos":57}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":658},"to":{"change":3,"start":658,"end":731},"introduced_by":3}],"inode":{"change":3,"pos":57}},"ins_contents":[{"Add":" opts.reqopt(\"d\", \"\", \"debounce delay in milliseconds\", \"TIMEOUT\");"}],"del_contents":[{"Del":" opts.reqopt(\"t\", \"\", \"debounce timeout in milliseconds\", \"TIMEOUT\");\n"}]}},{"Replacement":{"inode":{"change":3,"pos":57},"path":"examples/debounce.rs","line":14,"ins":{"up_context":[{"change":3,"pos":774}],"down_context":[{"change":3,"pos":992}],"flag":"BLOCK","start":3415,"end":3471,"inode":{"change":3,"pos":57}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":774},"to":{"change":3,"start":774,"end":832},"introduced_by":3}],"inode":{"change":3,"pos":57}},"ins_contents":[{"Add":" let delay = matches.opt_str(\"d\").unwrap().parse()?;"}],"del_contents":[{"Del":" let timeout = matches.opt_str(\"t\").unwrap().parse()?;\n"}]}},{"Replacement":{"inode":{"change":3,"pos":57},"path":"examples/debounce.rs","line":16,"ins":{"up_context":[{"change":3,"pos":993}],"down_context":[{"change":2,"pos":964}],"flag":"BLOCK","start":3472,"end":3648,"inode":{"change":3,"pos":57}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":993},"to":{"change":2,"start":870,"end":964},"introduced_by":2}],"inode":{"change":3,"pos":57}},"ins_contents":[{"Add":" // Create threaded debouncer"},{"Add":" let debouncer = EventDebouncer::new(Duration::from_millis(delay), move |data: String| {"},{"Add":" // Debounced strings are written to stdout"}],"del_contents":[{"Del":" let debouncer = EventDebouncer::new(Duration::from_millis(timeout), move |data: String| {\n"}]}},{"Edit":{"inode":{"change":3,"pos":57},"path":"examples/debounce.rs","line":22,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":1307}],"down_context":[{"change":3,"pos":1307}],"flag":"BLOCK","start":3649,"end":3710,"inode":{"change":3,"pos":57}}},"contents":[{"Add":" // Send strings from stdin to the debouncer indefinitely"}]}}],"owner":"isagalaev","repo":"debounce","token":"Uj42R3QzPV+oa3cA6I4UhHnpeNjk/7tY5Q+gwbu1k1w=","login":null}

…

Dependencies

Change contents