Do something with e.g. Channel.list(:wait(.5))

rakudo · Mar 15, 2015 · 997afa3 · 997afa3
1 parent bba8a3a
commit 997afa3
Showing 1 changed file with 12 additions and 1 deletion.
diff --git a/src/core/Channel.pm b/src/core/Channel.pm
@@ -91,7 +91,7 @@ my class Channel {
         }
     }
 
-    method list($self: :$wait = 0 ) {
+    multi method list(Channel:D $self:) {
         gather {
             loop {
                 earliest $self {
@@ -101,6 +101,17 @@ my class Channel {
             }
         }
     }
+    multi method list(Channel:D $self: :$wait! ) {
+        gather {
+            loop {
+                earliest $self {
+                  more * { take $_ }
+                  done * { last }
+                  wait $wait { Nil }
+                }
+            }
+        }
+    }
 
     method close() {
         $!closed = 1;