Improve stream controller tests
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