mdapena / pyventus / 21097156019

100%

push

github

Add `ObservableValue` definition (#48)

* Standardize task methods in AsyncIOProcessingService

* Add subscriber selection property to Observable emit methods

* Add tests for subscriber selection in Observable emit methods

* Update `wait_for_task` in `ObservableTask` to ensure task completion

* Remove unused variable from Observable tests

* Add ObservableValue

* Fix mypy errors in Observable tests.

* Update the wait_for_tasks method in AsyncIO

* Fix prime_subscriptions & improve async handling

* Add subscriber_condition param for Observable emit methods

* Enhance async execution order in ObservableValue

* Fix _emit_complete logic when conditions or selections are provided

* Update Observable emit tests to include the new condition parameter

* Add tests for ObservableValue

* Simplify the Observable emit methods

* Fix typing and import errors identified by Ruff

* Refactor ObservableValue to use new emit method implementations

* Enhance coverage of Observable tests

* Enhance `ObservableValue` methods/workflow consistency

* Update `ObservableValue` tests

* Fix Ruff errors and imports

* Add `ObservableValue` debug logs

* Updated Observable logs for consistency

* Add method to retrieve all tasks from AsyncIO processing services

* Add tests for AsyncIOProcessingService's all_tasks() method

595 of 595 new or added lines in 8 files covered. (100.0%)

3943 of 3943 relevant lines covered (100.0%)

14.97 hits per line