use streamqueue for sorted streams