Refactor concurrent read from multiple readers so it can used outside InputProcessor

[george-zubrienko]

No description provided.

[github-actions]

Coverage Report

File	Stmts	Miss	Cover	Missing
esd_services_api_client/beast/v3
_connector.py	107	80	25%	58–74, 81, 93, 101–119, 139–174, 187–218, 226, 251–254, 261–264, 275–292, 302–308, 317–323
_models.py	100	20	80%	46–50, 107–110, 119–127, 137–145, 153–156
esd_services_api_client/boxer
_auth.py	86	17	80%	42–43, 52–61, 70–76, 87
_connector.py	89	50	44%	54–58, 64–68, 74–76, 82–84, 92–99, 107–113, 121–128, 136–144, 179, 189–195, 209–218, 228–233
_models.py	27	2	93%	49–50
esd_services_api_client/crystal
_connector.py	119	52	56%	54–66, 75, 147, 150, 169–196, 208, 217, 238, 243–254, 273–292, 320, 332–342
esd_services_api_client/nexus/abstractions
logger_factory.py	16	16	0%	20–58
nexus_object.py	20	20	0%	21–61
socket_provider.py	12	12	0%	4–46
esd_services_api_client/nexus/algorithms
__init__.py	3	3	0%	20–22
_baseline_algorithm.py	15	15	0%	21–56
distributed.py	14	14	0%	21–53
minimalistic.py	10	10	0%	20–44
recursive.py	18	18	0%	21–58
esd_services_api_client/nexus/configurations
algorithm_configuration.py	8	8	0%	4–34
esd_services_api_client/nexus/core
app_core.py	110	110	0%	20–275
app_dependencies.py	80	80	0%	20–222
esd_services_api_client/nexus/exceptions
__init__.py	1	1	0%	20
_nexus_error.py	2	2	0%	21–27
input_reader_error.py	15	15	0%	20–51
startup_error.py	14	14	0%	21–48
esd_services_api_client/nexus/input
__init__.py	3	3	0%	21–23
_functions.py	27	27	0%	20–69
input_processor.py	17	17	0%	20–56
input_reader.py	43	43	0%	4–117
payload_reader.py	33	33	0%	20–83
tests
test_crystal_connector.py	88	1	99%	51
TOTAL	1198	683	43%

Tests	Skipped	Failures	Errors	Time
18	0 💤	0 ❌	0 🔥	14.033s ⏱️

[github-actions]

Coverage Report

File	Stmts	Miss	Cover	Missing
esd_services_api_client/beast/v3
_connector.py	107	80	25%	58–74, 81, 93, 101–119, 139–174, 187–218, 226, 251–254, 261–264, 275–292, 302–308, 317–323
_models.py	100	20	80%	46–50, 107–110, 119–127, 137–145, 153–156
esd_services_api_client/boxer
_auth.py	86	17	80%	42–43, 52–61, 70–76, 87
_connector.py	89	50	44%	54–58, 64–68, 74–76, 82–84, 92–99, 107–113, 121–128, 136–144, 179, 189–195, 209–218, 228–233
_models.py	27	2	93%	49–50
esd_services_api_client/crystal
_connector.py	118	52	56%	54–66, 75, 147, 150, 169–196, 208, 217, 238, 243–254, 273–292, 320, 332–342
esd_services_api_client/nexus/abstractions
logger_factory.py	16	16	0%	20–58
nexus_object.py	20	20	0%	21–61
socket_provider.py	12	12	0%	4–46
esd_services_api_client/nexus/algorithms
__init__.py	3	3	0%	20–22
_baseline_algorithm.py	15	15	0%	21–56
distributed.py	14	14	0%	21–53
minimalistic.py	10	10	0%	20–44
recursive.py	18	18	0%	21–58
esd_services_api_client/nexus/configurations
algorithm_configuration.py	8	8	0%	4–34
esd_services_api_client/nexus/core
app_dependencies.py	80	80	0%	20–222
esd_services_api_client/nexus/exceptions
__init__.py	1	1	0%	20
_nexus_error.py	2	2	0%	21–27
input_reader_error.py	15	15	0%	20–51
startup_error.py	14	14	0%	21–48
esd_services_api_client/nexus/input
__init__.py	3	3	0%	21–23
input_processor.py	17	17	0%	20–56
input_reader.py	43	43	0%	4–117
payload_reader.py	33	33	0%	20–83
tests
test_crystal_connector.py	88	1	99%	51
TOTAL	1060	546	48%

Tests	Skipped	Failures	Errors	Time
18	0 💤	0 ❌	0 🔥	13.885s ⏱️

[s-vitaliy]

LGTM