improved support for change stream

 - change stream class allows for use in for-comprehensions
 - better handling of closed streams