Пакетная обработка при использовании блокирующей коллекции

Question

У меня есть блокирующий набор, который должен быть обработан в течение 5 минут. Щас пользуюсь GetConsumingEnumerable() но я не хочу этого, вместо этого мне нужно пакетный процесс.

var reqs = MessageFactory.NetApiRequestQueue.GetConsumingEnumerable(token).ToObservable();           

reqs.SubscribeOn(ThreadPoolScheduler.Instance).Subscribe(x =>
{
});