go-pkgz / flow / 32218394553

91%

Build Type

push

github

Committed by web-flow

Commit Message

fix deadlock in Wait with unbuffered response channel (#7)

Wait returned eg.Wait() directly, so workers blocked in sender on the
default unbuffered response channel could never complete and Wait hung
forever unless the cursor was consumed. Wait now drains and discards
responses until the channel is closed, then returns the errgroup error,
keeping the existing error semantics.

Wait on a pool which was never activated returns an error instead of
panicking on the nil errgroup.

Coverage Stats

9 of 9 new or added lines in 1 file covered. (100.0%)

2 existing lines in 1 file now uncovered.

423 of 469 relevant lines covered (90.19%)

2715.3 hits per line