feat(stream_processor): Add clear_queues_on_update parameter
#61
+56
−0
clear_queues_on_update parameter
#61