Try the following code:
var subscription = Store.Changes();
await subscription.EnsureConnectedNow();
var observableWithTask = subscription
.ForDocumentsInCollection<ReferenceDataProvider>();
observableWithTask.Subscribe(change =>
{
Console.WriteLine("Data subscription changed");
Reinitialize();
});
await observableWithTask.EnsureSubscribedNow();
CLICK HERE to find out more related problems solutions.