dataflow: fix peek rate calculation
integration testing: flux: test infinite input stream