numaflow-go
numaflow-go copied to clipboard
add unit tests for EOF reduce streamer and session
https://github.com/numaproj/numaflow-go/pull/111#discussion_r1537708110
This should apply to both session reducer and stream reducer.