Added a pipe to rate limit streams