Move stream.subscribe() to be part of the constructor

Move stream.subscribe() to be part of the constructor #242