For each possible scenario, we generate. We need to provide a class for verifying that the events received on the changestream are actually matching with the expectations. 

The difficulty here is to track the list of actions and provide a customizable event checker to attach to the end state for each possible scenario. 

E.G

DabatabasePresentCollectionPresent<StartState> => insert doc => DabatabasePresentCollectionPresent<Event Checker> 

EventChecker will need to verify that changestream has received insert on the collection and possibly that the collection was setup correctly at the beginning.