.gitignore
LICENSE
README.md
pyproject.toml
requirements.txt
setup.py
apipeline/__init__.py
apipeline.egg-info/PKG-INFO
apipeline.egg-info/SOURCES.txt
apipeline.egg-info/dependency_links.txt
apipeline.egg-info/requires.txt
apipeline.egg-info/top_level.txt
apipeline/frames/__init__.py
apipeline/frames/app_frames.py
apipeline/frames/base.py
apipeline/frames/control_frames.py
apipeline/frames/data_frames.proto
apipeline/frames/data_frames.py
apipeline/frames/sys_frames.py
apipeline/frames/protobufs/__init__.py
apipeline/frames/protobufs/data_frames_pb2.py
apipeline/notifiers/__init__.py
apipeline/notifiers/base.py
apipeline/notifiers/event_notifier.py
apipeline/pipeline/__init__.py
apipeline/pipeline/base_pipeline.py
apipeline/pipeline/merge_pipeline.py
apipeline/pipeline/parallel_pipeline.py
apipeline/pipeline/pipeline.py
apipeline/pipeline/runner.py
apipeline/pipeline/sync_parallel_pipeline.py
apipeline/pipeline/task.py
apipeline/processors/__init__.py
apipeline/processors/async_frame_processor.py
apipeline/processors/frame_processor.py
apipeline/processors/idle_frame_processor.py
apipeline/processors/input_processor.py
apipeline/processors/logger.py
apipeline/processors/output_processor.py
apipeline/processors/text_transformer.py
apipeline/processors/user_idle_processor.py
apipeline/processors/aggregators/__init__.py
apipeline/processors/aggregators/gated.py
apipeline/processors/aggregators/hold.py
apipeline/processors/aggregators/sentence.py
apipeline/processors/filters/__init__.py
apipeline/processors/filters/frame_filter.py
apipeline/processors/filters/function_filter.py
apipeline/processors/filters/null_filter.py
apipeline/serializers/__init__.py
apipeline/serializers/base_serializer.py
apipeline/serializers/protobuf.py
apipeline/utils/__init__.py
apipeline/utils/obj.py
apipeline/utils/string.py
apipeline/utils/test_frame_processor.py
docs/design.md
docs/dev.md
docs/settings.json
examples/README.md
examples/sentence_aggregator.py
tests/__init__.py
tests/test_mock.py
tests/test_simple.py
tests/aggr/test_gated_aggr.py
tests/aggr/test_hold_aggr.py
tests/filter/test_frame_filter.py
tests/filter/test_func_filter.py
tests/pipeline/test_parallel_pipeline.py
tests/pipeline/test_pipeline.py
tests/pipeline/test_sync_parallel_pipeline.py
tests/serializer/test_protobuf_serializer.py