CompositeDataSource required to accept pivot table as an argument

gistfile1.cs

//Change the SubscribeMany line
var pivotLoader = _pivotTables.Connect()
.SubscribeMany(pivot => pivot.Data.Connect().Synchronize(_updateLocker).Subscribe(changes => PivotDataHasUpdated(pivot,changes)))
.Subscribe();

//Change the PivotDataHasUpdated signature
public void PivotDataHasUpdated(IDataSource pivotTable, IChangeSet<Record, Guid> changes)
{
  //...
}