Making internal state atomic
Testing fanning events in
Adding way to fan events out
Changes towards a StateStream
Creating StateStream class
Rejigging everything...
Using Sequential strategy in tests