Don't lose exceptions in Channel.Supply.

rakudo · Mar 9, 2016 · 6184e15 · 6184e15
1 parent fac3d74
commit 6184e15
Showing 1 changed file with 10 additions and 2 deletions.
diff --git a/src/core/Channel.pm b/src/core/Channel.pm
@@ -107,11 +107,19 @@ my class Channel {
                 emit got;
             }
             self!peek();
-            done() if $!closed_promise;
+            if $!closed_promise {
+                $!closed_promise.status == Kept
+                    ?? done()
+                    !! die $!closed_promise.cause
+            }
             whenever $!async-notify.unsanitized-supply.schedule-on($*SCHEDULER) {
                 my Mu \got = self.poll;
                 if nqp::eqaddr(got, Nil) {
-                    done() if $!closed_promise;
+                    if $!closed_promise {
+                        $!closed_promise.status == Kept
+                            ?? done()
+                            !! die $!closed_promise.cause
+                    }
                 }
                 else {
                     emit got;