refactor streaming actor