Mercurial > repos > AlgTools / changeset

--- a/src/Comms.jl	Wed Dec 11 18:45:34 2019 +0200
+++ b/src/Comms.jl	Wed Dec 18 21:32:27 2019 +0200
@@ -11,7 +11,8 @@
 ##############
 
 export process_channel,
-       put_onlylatest!
+       put_onlylatest!,
+       put_unless_closed!
 
 ####################
 # Channel iteration
@@ -31,8 +32,8 @@
         try
             fn(d)
         catch ex
-            error("Exception in process_channel handler. Terminating.\n$(ex)")
-            throw(ex)
+            error("Exception in process_channel handler. Terminating.\n")
+            rethrow(ex)
         end 
     end
 end
@@ -48,4 +49,21 @@
     put!(rc, d)
 end
 
+############################################
+# Cracefully return false if channel closed
+############################################
+
+function put_unless_closed!(rc, d)
+    try
+        put!(rc, d)
+    catch ex
+        if isa(ex, InvalidStateException) && ex.state==:closed
+            return false
+        else
+            rethrow(ex)
+        end
+    end
+    return true
+end
+
 end # Module