add stream shutdown and support half-duplex operation (#40783)

Fixes one of the issues mentioned in #24526
JuliaLang · Jul 29, 2021 · 2cb6904 · 2cb6904
1 parent 740a33a
commit 2cb6904
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/process_messages.jl b/src/process_messages.jl
@@ -230,8 +230,8 @@ function message_handler_loop(r_stream::IO, w_stream::IO, incoming::Bool)
             deregister_worker(wpid)
         end
 
-        isopen(r_stream) && close(r_stream)
-        isopen(w_stream) && close(w_stream)
+        close(r_stream)
+        close(w_stream)
 
         if (myid() == 1) && (wpid > 1)
             if oldstate != W_TERMINATING