Throttle

Definition

class broqer.op.Throttle(duration: float, error_callback=<broqer.error_handler.DefaultErrorHandler object>, loop=None)

Rate limit emits by the given time.

Parameters:

• duration – time for throttling in seconds
• error_callback – the error callback to be registered
• loop – asyncio event loop to use

Usage

Rate limit emits by the given time. Usage: >>> import asyncio >>> from broqer import Value, op, Sink >>> v = Value() >>> throttle_publisher = v | op.Throttle(0.1) >>> _d = throttle_publisher.subscribe(Sink(print)) >>> v.emit(1) 1 >>> v.emit(2) >>> asyncio.get_event_loop().run_until_complete(asyncio.sleep(0.05)) >>> v.emit(3) >>> asyncio.get_event_loop().run_until_complete(asyncio.sleep(0.2)) 3 >>> # It’s also possible to reset the throttling duration: >>> v.emit(4) 4 >>> v.emit(5) >>> asyncio.get_event_loop().run_until_complete(asyncio.sleep(0.05)) >>> throttle_publisher.reset()