Catch exception when trying to keep/break the closed promise

This is just a workaround until we figure out how to avoid !peek encountering a CHANNEL_CLOSE/CHANNEL_FAIL more than once.
rakudo · Sep 4, 2019 · 5aa998f · 5aa998f
1 parent 0f31d35
commit 5aa998f
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/core.c/Channel.pm6 b/src/core.c/Channel.pm6
@@ -103,11 +103,11 @@ my class Channel does Awaitable {
             Nil
         } else {
             if nqp::istype(msg, CHANNEL_CLOSE) {
-                $!closed_promise_vow.keep(Nil);
+                try $!closed_promise_vow.keep(Nil);
                 Nil
             }
             elsif nqp::istype(msg, CHANNEL_FAIL) {
-                $!closed_promise_vow.break(msg.error);
+                try $!closed_promise_vow.break(msg.error);
                 Nil
             }
             else {