Fix Supply.zip watermark changes

We are only done when all supplies hit the watermark, not when the first hits the mark.
rakudo · Feb 21, 2023 · 2225e20 · 2225e20
1 parent 6e2a46f
commit 2225e20
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/src/core.c/Supply-coercers.pm6 b/src/core.c/Supply-coercers.pm6
@@ -789,9 +789,9 @@
                 if &with {
                     whenever $supply -> \val {
                         @values[$index].push(val);
-                        my $new-count = @counts[$index]++;
+                        @counts[$index]++;
                         emit( [[&with]] @values.map(*.shift) ) if all(@values);
-                        done if $new-count == $watermark;
+                        done if all(@counts) >= $watermark;
                         LAST {
                             $watermark min= @counts[$index];
                             done if all(@counts) >= $watermark;
@@ -801,9 +801,9 @@
                 else {
                     whenever $supply -> \val {
                         @values[$index].push(val);
-                        my $new-count = @counts[$index]++;
+                        @counts[$index]++;
                         emit( $(@values.map(*.shift).list.eager) ) if all(@values);
-                        done if $new-count == $watermark;
+                        done if all(@counts) >= $watermark;
                         LAST {
                             $watermark min= @counts[$index];
                             done if all(@counts) >= $watermark;