Removes stream.ensure() usage