Use a seperate process to manage the stream subscription