Move to mongoose based streaming