You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
I've looked into the OperationCombineLatest implementation and I think it is incorrectly implemented:
Doesn't seem to allow multiple observers on the same combiner as the Aggregator is per source observable and not per subscribing observer.
I think the contract requires that no onNext value is lost on any of the source observers yet since they are not synchronized with each other, a source observer might overwrite its current value while the collection is running in Aggregator.next().
Thoughts?
Edit: I was wrong with case 2; if one is faster than the others, that is not a problem.
The text was updated successfully, but these errors were encountered:
I've looked into the
OperationCombineLatest
implementation and I think it is incorrectly implemented:Aggregator.next()
.Thoughts?
Edit: I was wrong with case 2; if one is faster than the others, that is not a problem.
The text was updated successfully, but these errors were encountered: