Fix Channel.close

it did not immediately fulfill the .closed promise if $!queue was empty
rakudo · Feb 7, 2015 · 3f9508c · 3f9508c
1 parent bf3e3ab
commit 3f9508c
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/core/Channel.pm b/src/core/Channel.pm
@@ -103,6 +103,9 @@ my class Channel {
     method close() {
         $!closed = 1;
         nqp::push($!queue, CHANNEL_CLOSE);
+        # if $!queue is otherwise empty, make sure that $!closed_promise
+        # learns about the new value
+        self!peek();
         Nil
     }