public final static < T > Stream < T > debounce ( final Stream < T > stream , final long time , final TimeUnit t ) { return new DebounceOperator <> ( stream ) . debounce ( time , t ) ; }
Allow one element through per time period drop all other elements in that time period