A cheating, eager gather/take.

Gets us by for the basic things for now, until MoarVM has continuation support implemented.
rakudo · Dec 18, 2013 · c5ecb99 · c5ecb99
1 parent 0df06cf
commit c5ecb99
Showing 1 changed file with 22 additions and 1 deletion.
diff --git a/src/core/GatherIter.pm b/src/core/GatherIter.pm
@@ -6,6 +6,9 @@ class GatherIter is Iterator {
 #?if jvm
     my $GATHER_PROMPT = [];
     my $SENTINEL := [];
+#?endif
+#?if moar
+    my $SENTINEL := [];
 #?endif
     method new($block, Mu :$infinite) {
 #?if parrot
@@ -29,7 +32,22 @@ class GatherIter is Iterator {
         my $coro := sub () is rw { nqp::continuationreset($GATHER_PROMPT, $state); $takings };
 #?endif
 #?if moar
-        my $coro = die 'GatherIter NYI on MoarVM';
+        # XXX Cheating, eager implementation for now.
+        my int $done = 0;
+        my $coro := -> {
+            if $done {
+                $SENTINEL
+            }
+            else {
+                my Mu $takings := nqp::list();
+                nqp::handle($block().eager(),
+                    'TAKE', nqp::stmts(
+                        nqp::push($takings, nqp::getpayload(nqp::exception())),
+                        nqp::resume(nqp::exception())));
+                $done = 1;
+                nqp::p6parcel($takings, Mu)
+            }
+        }
 #?endif
         my Mu $new := nqp::create(self);
         nqp::bindattr($new, GatherIter, '$!coro', $coro);
@@ -62,6 +80,9 @@ class GatherIter is Iterator {
 #?endif
 #?if jvm
                 $end = nqp::p6bool(nqp::eqaddr($parcel, $SENTINEL));
+#?endif
+#?if moar
+                $end = nqp::p6bool(nqp::eqaddr($parcel, $SENTINEL));
 #?endif
                 nqp::push($rpa, $parcel) unless $end;
                 $count = $count - 1;