Integration tests now passing with concurrency. Fixed a bug with FanoutDataObserver that lead to a bad test
Simplified ChangeBuffer now that FanoutDataObserver no longer uses it