public final static < T > Stream < T > onePer ( final Stream < T > stream , final long time , final TimeUnit t ) { return new OnePerOperator <> ( stream ) . onePer ( time , t ) ; }
emit one element per time period