StreamController calls a function in Topics -> Partitions to set the boolean "Partition.IsPaused".
This introduced synchronisation issues between the IsPaused boolean in StreamController and the IsPaused boolean inside every Partition instance, mainly due to the fact that the list of Partitions can dynamically change AFTER StreamController.IsPaused has been set.
Description of work
This change uses a different approach, where Partitions receive a lambda function with access to StreamController's IsPaused variable.
Checklist
[ ] Changes have been documented in changes.md
[ ] Documentation has been updated in documentation directory
Issue
ECDC-3253
StreamController calls a function in Topics -> Partitions to set the boolean "Partition.IsPaused". This introduced synchronisation issues between the IsPaused boolean in StreamController and the IsPaused boolean inside every Partition instance, mainly due to the fact that the list of Partitions can dynamically change AFTER StreamController.IsPaused has been set.
Description of work
This change uses a different approach, where Partitions receive a lambda function with access to StreamController's IsPaused variable.
Checklist
changes.mddocumentationdirectory