I was torn about that. It seamed like the threshold could get huge. I'll change it and move the throttling logic into TupleOutputStreamProcessor since it knows about how many streams it has.