python - 使用关闭选择器功能的 RxPY 缓冲区示例？

Question

寻找一个使用 RxPy 的示例，其中使用关闭选择器函数来决定何时关闭缓冲区来完成缓冲。在我的示例中，我希望能够根据在 observables 数据本身中看到的值来关闭缓冲区边界。我假设使用关闭选择器是这样做的方法。