Add Rx. Now an observable stream.