Commit c8539561 authored by Sebastian Stammler's avatar Sebastian Stammler

op-batcher: Fix channelBuilder.OutputFrames to check for full channel

It only checked whether the input target was reached. But it should
also close the underlying channel out if it is full for any other
reason.
parent a013539c
......@@ -173,7 +173,7 @@ func (c *channelBuilder) setFullErr(err error) {
// If the target has been reached, the channel is closed and all remaining
// frames will be created, possibly with a small leftover frame.
func (c *channelBuilder) OutputFrames() error {
if c.InputTargetReached() {
if c.IsFull() {
return c.closeAndOutputAllFrames()
}
return c.outputReadyFrames()
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment