LICENSE
README.md
pyproject.toml
setup.cfg
setup.py
PipeRT.egg-info/PKG-INFO
PipeRT.egg-info/SOURCES.txt
PipeRT.egg-info/dependency_links.txt
PipeRT.egg-info/requires.txt
PipeRT.egg-info/top_level.txt
demo/__init__.py
demo/demo.py
demo/demo_unlink.py
demo/simple-demo.py
demo/rpc/__init__.py
demo/rpc/rpc_client_pipe.py
demo/rpc/rpc_server_pipe.py
demo/rpc/utlis.py
demo/socket_logger/__init__.py
demo/socket_logger/custom_events.py
demo/socket_logger/video_stream.py
pipert2/__init__.py
pipert2/contrib/__init__.py
pipert2/contrib/message_handlers/__init__.py
pipert2/contrib/networks/__init__.py
pipert2/contrib/routines/__init__.py
pipert2/core/__init__.py
pipert2/core/base/__init__.py
pipert2/core/base/data_transmitter.py
pipert2/core/base/flow.py
pipert2/core/base/message.py
pipert2/core/base/payload.py
pipert2/core/base/pipe.py
pipert2/core/base/routine.py
pipert2/core/base/wire.py
pipert2/core/base/data/__init__.py
pipert2/core/base/data/data.py
pipert2/core/base/data/frame_data.py
pipert2/core/base/routines/__init__.py
pipert2/core/base/routines/extended_run_factory.py
pipert2/core/base/routines/fps_routine.py
pipert2/core/base/routines/functional_middle_routine.py
pipert2/core/base/synchronise_routines/__init__.py
pipert2/core/base/synchronise_routines/routines_synchroniser.py
pipert2/core/base/synchronise_routines/synchroniser_node.py
pipert2/core/base/transmitters/__init__.py
pipert2/core/base/transmitters/basic_transmitter.py
pipert2/core/base/transmitters/shared_memory_transmitter.py
pipert2/core/base/validators/__init__.py
pipert2/core/base/validators/flow_validator.py
pipert2/core/handlers/__init__.py
pipert2/core/handlers/event_handler.py
pipert2/core/handlers/message_handler.py
pipert2/core/handlers/message_handlers/__init__.py
pipert2/core/handlers/message_handlers/queue_handler.py
pipert2/core/managers/__init__.py
pipert2/core/managers/event_board.py
pipert2/core/managers/network.py
pipert2/core/managers/networks/__init__.py
pipert2/core/managers/networks/queue_network.py
pipert2/core/wrappers/__init__.py
pipert2/core/wrappers/api_wrapper.py
pipert2/core/wrappers/rpc_pipe_wrapper.py
pipert2/core/wrappers/utils.py
pipert2/utils/__init__.py
pipert2/utils/annotations.py
pipert2/utils/base_event_executor.py
pipert2/utils/batch_notifier.py
pipert2/utils/dummy_object.py
pipert2/utils/logging_module_modifiers.py
pipert2/utils/method_data.py
pipert2/utils/routine_type_identifier.py
pipert2/utils/singleton.py
pipert2/utils/singleton_abs.py
pipert2/utils/consts/__init__.py
pipert2/utils/consts/emit_socket_names.py
pipert2/utils/consts/event_names.py
pipert2/utils/consts/routine_types.py
pipert2/utils/consts/synchronise_routines.py
pipert2/utils/data_class/__init__.py
pipert2/utils/data_class/dataclasses.py
pipert2/utils/exceptions/__init__.py
pipert2/utils/exceptions/floating_routine.py
pipert2/utils/exceptions/queue_not_initialized.py
pipert2/utils/exceptions/unique_routine_name.py
pipert2/utils/exceptions/wires_validation.py
pipert2/utils/interfaces/__init__.py
pipert2/utils/interfaces/event_executor_interface.py
pipert2/utils/queue_utils/__init__.py
pipert2/utils/queue_utils/publish_queue.py
pipert2/utils/queue_utils/queue_wrapper.py
pipert2/utils/shared_memory/__init__.py
pipert2/utils/shared_memory/general/__init__.py
pipert2/utils/shared_memory/general/memory_id_iterator.py
pipert2/utils/shared_memory/general/shared_memory_manager.py
pipert2/utils/shared_memory/multiprocessing/__init__.py
pipert2/utils/shared_memory/multiprocessing/shared_memory_generator.py
pipert2/utils/shared_memory/multiprocessing/shared_memory_manager.py
pipert2/utils/shared_memory/posix_ipc/__init__.py
pipert2/utils/shared_memory/posix_ipc/shared_memory.py
pipert2/utils/shared_memory/posix_ipc/shared_memory_generator.py
pipert2/utils/shared_memory/posix_ipc/shared_memory_manager.py
pipert2/utils/socketio_logger/__init__.py
pipert2/utils/socketio_logger/frame_utils.py
pipert2/utils/socketio_logger/socket_formatter.py
pipert2/utils/socketio_logger/socket_handler.py
pipert2/utils/socketio_logger/socket_logger.py
tests/__init__.py
tests/end_to_end/__init__.py
tests/end_to_end/test_pipe_auto_pacing_mechanism_disabled.py
tests/end_to_end/test_pipe_auto_pacing_mechanism_enabled.py
tests/end_to_end/utils/__init__.py
tests/end_to_end/utils/routines/__init__.py
tests/end_to_end/utils/routines/destination_counter_routine.py
tests/end_to_end/utils/routines/destination_saving_routine.py
tests/end_to_end/utils/routines/middle_buffering_routine.py
tests/end_to_end/utils/routines/middle_counter_routine.py
tests/end_to_end/utils/routines/source_counter_routine.py
tests/end_to_end/utils/routines/source_generating_routine.py
tests/integration/__init__.py
tests/integration/pipert/__init__.py
tests/integration/pipert/core/__init__.py
tests/integration/pipert/core/base/__init__.py
tests/integration/pipert/core/base/test_pipe_integrate_with_flow.py
tests/integration/pipert/core/managers/__init__.py
tests/integration/pipert/core/managers/networks/__init__.py
tests/integration/pipert/core/managers/networks/test_queue_network.py
tests/unit/__init__.py
tests/unit/pipert/__init__.py
tests/unit/pipert/core/__init__.py
tests/unit/pipert/core/base/__init__.py
tests/unit/pipert/core/base/test_data_transmitter.py
tests/unit/pipert/core/base/test_flow.py
tests/unit/pipert/core/base/test_message.py
tests/unit/pipert/core/base/test_payload.py
tests/unit/pipert/core/base/test_pipe.py
tests/unit/pipert/core/base/routines/__init__.py
tests/unit/pipert/core/base/routines/test_destination_routine.py
tests/unit/pipert/core/base/routines/test_functional_middle_routine.py
tests/unit/pipert/core/base/routines/test_middle_routine.py
tests/unit/pipert/core/base/routines/test_source_routine.py
tests/unit/pipert/core/base/synchronizer_routines/__init__.py
tests/unit/pipert/core/base/synchronizer_routines/test_routines_synchronizer.py
tests/unit/pipert/core/base/synchronizer_routines/test_synchronizer_node.py
tests/unit/pipert/core/base/validators/__init__.py
tests/unit/pipert/core/base/validators/test_flow_validator.py
tests/unit/pipert/core/handlers/__init__.py
tests/unit/pipert/core/handlers/message_handlers/__init__.py
tests/unit/pipert/core/handlers/message_handlers/test_queue_handler.py
tests/unit/pipert/core/managers/__init__.py
tests/unit/pipert/core/managers/test_event_board.py
tests/unit/pipert/core/managers/networks/__init__.py
tests/unit/pipert/core/managers/networks/test_queue_network.py
tests/unit/pipert/core/utils/__init__.py
tests/unit/pipert/core/utils/events_utils.py
tests/unit/pipert/core/utils/functions_test_utils.py
tests/unit/pipert/core/utils/test_logging_modifiers.py
tests/unit/pipert/core/utils/test_method_data.py
tests/unit/pipert/core/utils/test_publish_queue.py
tests/unit/pipert/core/utils/test_queue_wrapper.py
tests/unit/pipert/core/utils/test_routine_type_identifier.py
tests/unit/pipert/core/utils/test_shared_memory_manager.py
tests/unit/pipert/core/utils/dummy_routines/__init__.py
tests/unit/pipert/core/utils/dummy_routines/dummy_destination_routine.py
tests/unit/pipert/core/utils/dummy_routines/dummy_middle_routine.py
tests/unit/pipert/core/utils/dummy_routines/dummy_source_routine.py
tests/unit/pipert/core/wrappers/__init__.py
tests/unit/pipert/core/wrappers/test_api_wrapper.py