Skip to content

Check write queue size with a lambda

Afonso Mukai requested to merge ECDC-3253_use_lambda into main

Created by: danesss

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 have been documented in changes.md
  • Documentation has been updated in documentation directory

Merge request reports