The current version should only be used for testing; for example, if you want to create a bunch of streams for stress testing, you can run this in a loop. (imported from commit ec51a431fb9679fc18379e4c6ecdba66bc75a395)