We now use "map" to have our inner generator of topics be mapped to objects with both the stream and topic. Thanks to Mahim Goyal for helping with this design.