Пример буфера RxPY с использованием закрывающей селекторной функции?

Question

Ищем пример использования RxPy, где буферизация выполняется с использованием закрывающей селекторной функции, чтобы решить, когда закрывать буфер. В моем примере я хочу иметь возможность закрыть границы моего буфера на основе значений, видимых в самих данных наблюдаемых. Я предполагаю, что использование закрывающего селектора является способом сделать это.