Thanks Sasajuric,
I believe this is what genstage is meant to do. When the writer is available, it sends demand (a number) back up through the processing pipeline so the producer knows it can send up to “demand” number of events to the writer.
The problem is, it’s not working. Which is why I introduced this extra buffering mechanism and why i’m asking the question.
I guess i wasn’t very clear about my first problem in my own mind. It’s really that I need help with debugging genstage!
Thanks