-
Notifications
You must be signed in to change notification settings - Fork 23
Description
See #250
idxInSync is supposed to be set when indexes are not up-to-date. And that's true when processing existing data. But when new data is injected after the indexes are marked as "live", idxInSync is never set again, which means you can never do a synchronous operation like publishing and then asking the indexes for results (which at least one of the broken tests tries to do) because you have no way of knowing when the indexes are done processing their new data. We really need some method of tracking new changes to the receiveLog and when they come in s.idxInSync.Add(1) until the message has gone through all of the indexes, at which point it is cleared with s.idxInSync.Done(). This would allow the existing WaitUntilIndexesAreSynced() function to actually work properly.
Metadata
Metadata
Assignees
Labels
Type
Projects
Status