Method time_buffered

src/react/observable.py:71–72

(self, period_millis, aggregate_function=None)

                LOGGER.exception('Could not notify on_close, observer ' + str(observer))

    def time_buffered(self, period_millis, aggregate_function=None):
        return _TimeBufferedPipe(self, period_millis, aggregate_function)

    def map(self, map_function):
        return _MappedPipe(self, map_function)