Carefully crafted library to operate with continuous streams of data in a reactive style with publish/subscribe, asyncio support and broker functionality.
Version to prepare the jump to version 1.0
op.map_threaded
op.just
Hub
.reset()
to op.debounce
and op.throttle
retrigger_value
to op.debounce
duetime
attibute to op.debounce
Minor documentation fixes