Small stream queue API change