Skip to content

Improve stream controller tests

Afonso Mukai requested to merge ECDC-3253_improve_StreamController_tests into main

Created by: danesss

Issue

ECDC-3253

Description of work

https://github.com/ess-dmsc/kafka-to-nexus/pull/686 adapted the consumption rate to the file writing rate to avoid out-of-memory issues due to WriteQueue buffering.

This PR makes some additional changes to ease testing of that feature.

  • MessageWriter is injected into StreamController instead of created inside it.
  • Additional tests are added to StreamController

Nominate for Group Code Review

  • Nominate for code review

Reminder

Changes should be documented in changes.md

Merge request reports