stream_processor
tests
