I think Stream() would be a good place for this, what does everyone else think? We should also be sure to handle cases such as https://github.com/nodejs/node/issues/28194