{"header":{"message":"Initial commit","description":null,"timestamp":"2021-10-13T04:17:23.460411367Z","authors":[{}]},"hash":"U5KNSQ77TIOWPR7H276RHQJMVHC4TWCDGGRM65LQ5VSPPGHUCY7QC","authors":[{"login":"isagalaev","key":"GGyJA92mZf4oyvR5S2XWq6i2USZKkrxmabqwBcQpBwSe"}],"deps":{"hashes":[["U5KNSQ77TIOWPR7H276RHQJMVHC4TWCDGGRM65LQ5VSPPGHUCY7QC","Initial commit"],["AA",null]],"deps":[],"known":[]},"hunks":[{"FileAdd":{"meta":{"basename":"src","metadata":576},"context":[{"change":1,"pos":0}],"contents":[]}},{"FileAdd":{"meta":{"basename":"lib.rs","metadata":0},"context":[{"change":0,"pos":15}],"contents":[{"Add":"#![feature(binary_heap_retain)]"},{"Add":""},{"Add":"use std::cmp::Ordering;"},{"Add":"use std::collections::{BinaryHeap, VecDeque};"},{"Add":"use std::time::{Duration, Instant};"},{"Add":""},{"Add":"#[derive(Debug, PartialEq, Eq)]"},{"Add":"struct Event {"},{"Add":" item: T,"},{"Add":" release_at: Instant,"},{"Add":"}"},{"Add":""},{"Add":"impl Ord for Event {"},{"Add":" fn cmp(&self, other: &Self) -> Ordering {"},{"Add":" other.release_at.cmp(&self.release_at) // reverse ordering for min-heap"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"impl PartialOrd for Event {"},{"Add":" fn partial_cmp(&self, other: &Self) -> Option {"},{"Add":" Some(self.cmp(other))"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"#[derive(Debug, PartialEq)]"},{"Add":"pub enum State {"},{"Add":" Ready(T),"},{"Add":" Wait(Duration),"},{"Add":" Empty,"},{"Add":"}"},{"Add":""},{"Add":"pub struct Debouncer {"},{"Add":" events: BinaryHeap>,"},{"Add":"}"},{"Add":""},{"Add":"impl Debouncer {"},{"Add":" pub fn new() -> Debouncer {"},{"Add":" Debouncer {"},{"Add":" events: BinaryHeap::new(),"},{"Add":" }"},{"Add":" }"},{"Add":""},{"Add":" pub fn put(&mut self, item: T, delay: Duration) {"},{"Add":" let time = Instant::now();"},{"Add":" self.events"},{"Add":" .retain(|e| e.release_at <= time || e.item != item);"},{"Add":" self.events.push(Event {"},{"Add":" item,"},{"Add":" release_at: time + delay,"},{"Add":" });"},{"Add":" }"},{"Add":""},{"Add":" pub fn get(&mut self) -> State {"},{"Add":" let time = Instant::now();"},{"Add":" match self.events.peek() {"},{"Add":" None => State::Empty,"},{"Add":" Some(e) if e.release_at > time => State::Wait(e.release_at - time),"},{"Add":" Some(_) => State::Ready(self.events.pop().unwrap().item),"},{"Add":" }"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"pub struct UniformDebouncer {"},{"Add":" delay: Duration,"},{"Add":" events: VecDeque>,"},{"Add":"}"},{"Add":""},{"Add":"impl UniformDebouncer {"},{"Add":" pub fn new(delay: Duration) -> UniformDebouncer {"},{"Add":" UniformDebouncer {"},{"Add":" delay,"},{"Add":" events: VecDeque::new(),"},{"Add":" }"},{"Add":" }"},{"Add":""},{"Add":" pub fn put(&mut self, item: T) {"},{"Add":" let time = Instant::now();"},{"Add":" self.events"},{"Add":" .retain(|e| e.release_at <= time || e.item != item);"},{"Add":" self.events.push_back(Event {"},{"Add":" item,"},{"Add":" release_at: time + self.delay,"},{"Add":" });"},{"Add":" }"},{"Add":""},{"Add":" pub fn get(&mut self) -> State {"},{"Add":" let time = Instant::now();"},{"Add":" match self.events.get(0) {"},{"Add":" None => State::Empty,"},{"Add":" Some(e) if e.release_at > time => State::Wait(e.release_at - time),"},{"Add":" Some(_) => State::Ready(self.events.pop_front().unwrap().item),"},{"Add":" }"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"#[cfg(test)]"},{"Add":"mod tests {"},{"Add":" use super::*;"},{"Add":" use std::thread::sleep;"},{"Add":" use std::time::Duration;"},{"Add":""},{"Add":" mod debouncer {"},{"Add":" use super::*;"},{"Add":""},{"Add":" #[test]"},{"Add":" fn wait() {"},{"Add":" let mut debouncer = Debouncer::new();"},{"Add":" debouncer.put(1, Duration::from_millis(20));"},{"Add":" assert!(matches!(debouncer.get(), State::Wait(_)));"},{"Add":" sleep(Duration::from_millis(10));"},{"Add":" assert!(matches!(debouncer.get(), State::Wait(_)));"},{"Add":" sleep(Duration::from_millis(10));"},{"Add":" assert!(matches!(debouncer.get(), State::Ready(_)));"},{"Add":" }"},{"Add":""},{"Add":" #[test]"},{"Add":" fn deduplication() {"},{"Add":" let mut debouncer = Debouncer::new();"},{"Add":" debouncer.put(1, Duration::from_millis(20));"},{"Add":" debouncer.put(2, Duration::from_millis(30));"},{"Add":" sleep(Duration::from_millis(10));"},{"Add":" debouncer.put(1, Duration::from_millis(10));"},{"Add":" sleep(Duration::from_millis(20));"},{"Add":" assert_eq!("},{"Add":" vec![debouncer.get(), debouncer.get(), debouncer.get()],"},{"Add":" vec![State::Ready(1), State::Ready(2), State::Empty]"},{"Add":" );"},{"Add":" }"},{"Add":""},{"Add":" #[test]"},{"Add":" fn event_order() {"},{"Add":" let mut debouncer = Debouncer::new();"},{"Add":" debouncer.put(2, Duration::from_millis(20));"},{"Add":" debouncer.put(1, Duration::from_millis(10));"},{"Add":" sleep(Duration::from_millis(30));"},{"Add":" assert_eq!("},{"Add":" vec![debouncer.get(), debouncer.get()],"},{"Add":" vec![State::Ready(1), State::Ready(2)]"},{"Add":" );"},{"Add":" }"},{"Add":" }"},{"Add":""},{"Add":" mod uniform_debouncer {"},{"Add":" use super::*;"},{"Add":""},{"Add":" #[test]"},{"Add":" fn wait() {"},{"Add":" let mut debouncer = UniformDebouncer::new(Duration::from_millis(20));"},{"Add":" debouncer.put(1);"},{"Add":" assert!(matches!(debouncer.get(), State::Wait(_)));"},{"Add":" sleep(Duration::from_millis(10));"},{"Add":" assert!(matches!(debouncer.get(), State::Wait(_)));"},{"Add":" sleep(Duration::from_millis(10));"},{"Add":" assert!(matches!(debouncer.get(), State::Ready(_)));"},{"Add":" }"},{"Add":""},{"Add":" #[test]"},{"Add":" fn deduplication() {"},{"Add":" let mut debouncer = UniformDebouncer::new(Duration::from_millis(20));"},{"Add":" debouncer.put(1);"},{"Add":" debouncer.put(2);"},{"Add":" sleep(Duration::from_millis(10));"},{"Add":" debouncer.put(1);"},{"Add":" sleep(Duration::from_millis(20));"},{"Add":" assert_eq!("},{"Add":" vec![debouncer.get(), debouncer.get(), debouncer.get()],"},{"Add":" vec![State::Ready(2), State::Ready(1), State::Empty]"},{"Add":" );"},{"Add":" }"},{"Add":" }"},{"Add":"}"}]}},{"FileAdd":{"meta":{"basename":"LICENSE","metadata":0},"context":[{"change":1,"pos":0}],"contents":[{"Add":"Copyright (c) 2021 Ivan Sagalaev. All rights reserved."},{"Add":""},{"Add":"Redistribution and use in source and binary forms, with or without modification,"},{"Add":"are permitted provided that the following conditions are met:"},{"Add":""},{"Add":"1. Redistributions of source code must retain the above copyright notice,"},{"Add":"this list of conditions and the following disclaimer."},{"Add":""},{"Add":"2. Redistributions in binary form must reproduce the above copyright notice,"},{"Add":"this list of conditions and the following disclaimer in the documentation"},{"Add":"and/or other materials provided with the distribution."},{"Add":""},{"Add":"3. Neither the name of the copyright holder nor the names of its contributors"},{"Add":"may be used to endorse or promote products derived from this software without"},{"Add":"specific prior written permission."},{"Add":""},{"Add":"THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS \"AS IS\""},{"Add":"AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE"},{"Add":"IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE"},{"Add":"ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE"},{"Add":"LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL"},{"Add":"DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR"},{"Add":"SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER"},{"Add":"CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,"},{"Add":"OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE"},{"Add":"USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE."}]}},{"FileAdd":{"meta":{"basename":"Cargo.toml","metadata":0},"context":[{"change":1,"pos":0}],"contents":[{"Add":"[package]"},{"Add":"name = \"debounce\""},{"Add":"version = \"0.1.0\""},{"Add":"edition = \"2018\""},{"Add":"authors = [\"Ivan Sagalaev \"]"},{"Add":"repository = \"https://nest.pijul.com/isagalaev/debounce\""},{"Add":"license = \"BSD-3-Clause\""},{"Add":""},{"Add":"# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html"},{"Add":""},{"Add":"[dependencies]"}]}},{"FileAdd":{"meta":{"basename":".ignore","metadata":0},"context":[{"change":1,"pos":0}],"contents":[{"Add":"/target"},{"Add":"Cargo.lock"}]}}],"owner":"isagalaev","repo":"debounce","token":"d+7wfYcBHOjPd75+3mro/GQQjzdzbniJ/Bjp2seucek=","login":null}

…

Dependencies

Change contents