At present, the streams code has a dependency on the query system of the MongoDB server. As such, this code should be audited and ownership should be given to query where appropriate such that the query team is aware of any changes that affect the query team