Move stream message parser to separate actor