stream_processor
