Fix bugs in sink of HyperSeq/RaceSeq

Remember to mark batches consumed, and construct the Sink correctly.
rakudo · Oct 17, 2017 · 41729e9 · 41729e9
1 parent ad0dd8e
commit 41729e9
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/core/Rakudo/Internals/HyperRaceSharedImpl.pm b/src/core/Rakudo/Internals/HyperRaceSharedImpl.pm
@@ -65,6 +65,7 @@ class Rakudo::Internals::HyperRaceSharedImpl {
         has int $!batches-seen = 0;
         method consume-batch(Rakudo::Internals::HyperWorkBatch $batch --> Nil) {
             $!batches-seen++;
+            self.batch-used();
             if $batch.last {
                 $!last-target = $batch.sequence-number;
             }
@@ -79,7 +80,7 @@ class Rakudo::Internals::HyperRaceSharedImpl {
     }
     method sink(\hyper, $source --> Nil) {
         if hyper.DEFINITE {
-            my $sink = Sink.new($source);
+            my $sink = Sink.new(:$source);
             Rakudo::Internals::HyperPipeline.start($sink, hyper.configuration);
             $*AWAITER.await($sink.complete);
             CATCH {