Implementing init state & real time state consistency.

Created a special "pausable" Subject that can be used for any data set that needs a consistency between iterator creation and change notification stream.