diff --git a/heap_manager.go b/heap_manager.go index 757d5a5..bac9d94 100644 --- a/heap_manager.go +++ b/heap_manager.go @@ -73,6 +73,7 @@ select { case data.iter <- b: case <-data.drop: + break } } close(data.iter) @@ -82,6 +83,7 @@ select { case data.iter <- heap.Pop(&bHeap).(*Bar): case <-data.drop: + break } } close(data.iter)