Use takeWhile to end watch stream.