CHANGELOG.md

3.0.3

• Fix missing error_callback call in SinkAsync (thanks to Patrick Kaulfus)

3.0.2

• fixed liniting errors

3.0.1

• merge #43: wheel dependency updated
• fixing #43: fixed wrong reference of internal module

3.0.0

• fixed typo ("orginator" fixed to "originator")
• add log output for default error_handler
• add dependent_subscribe function for Values
• remove OperatorFactory logic from operators
• remove Concat operator
• add CoroQueue to be used in MapAsync and SinkAsync

2.4.0

• changed default behavior of error_handler: now it raises an exception

2.3.3

• added broqer.Timer class and rewrite op.Throttle to use that class

2.3.2

• added PollPublisher

2.3.1

• fix OnEmitFuture behavior when using omit_subscription argument

2.3.0

• added Cache operator

2.2.0

• added Throttle operator (thanks to @flofeurstein )

2.1.0

• .reset_state is now calling .reset_state for all subscribers

2.0.3

• prevent iteration over a publisher
• fix another bug in BitwiseCombineLatest (emitted NONE when no publisher had state)

2.0.2

• fixed behaviour for BitwiseCombineLatest when a Publisher has state NONE

2.0.1

• fixed problem in Publisher.register_on_subscription_callback() when subscriptions already are available

2.0.0

• replace bumpversion by use_scm_version
• replace pylint by pylama
• fixed Publisher.notify bug (39d17642610ff86c9264986788e929419f007803)
• added BitwiseCombineLatest and map_bit operator
• added Not operator
• remove Pipfile functionality

2.0.0rc1

• rename default_error_handler.py to error_handler.py
• added BitwiseCombineLatest and map_bit
• fixing typing warnings