Возможно ли использовать Observable.Buffer для чего-то другого, кроме времени?

Я искал примеры того, как использовать Observable.Buffer в rx, но не могу найти ничего более существенного, чем стандартная временная буферизация.

Похоже, существует перегрузка для указания «bufferClosingSelector», но я не могу понять это.

Я пытаюсь создать последовательность, которая буферизуется по времени или по «накоплению». Рассмотрим поток запросов, в котором каждый запрос имеет какой-то вес, и я не хочу обрабатывать более x накопленного веса за раз, или, если накопилось недостаточно, просто дайте мне то, что пришло за последний период времени (обычная функциональность буфера )