Change at-async to at-spawn

Author: quinnj

src/Connections.jl

@@ -299,7 +299,7 @@ function IOExtras.closeread(c::Connection)
     c.readable = false
     @debugv 3 "✉️  Read done: $c"
     if c.clientconnection
-        t = @async monitor_idle_connection(c)
+        t = Threads.@spawn monitor_idle_connection(c)
         @isdefined(errormonitor) && errormonitor(t)
     end
     return

src/Exceptions.jl

@@ -28,17 +28,15 @@ end # @eval
 function try_with_timeout(f, timeout)
     ch = Channel(0)
     timer = Timer(tm -> close(ch, TimeoutError(timeout)), timeout)
-    @async begin
-        try
-            put!(ch, $f())
-        catch e
-            if !(e isa HTTPError)
-                e = CapturedException(e, catch_backtrace())
-            end
-            close(ch, e)
-        finally
-            close(timer)
+    Threads.@spawn try
+        put!(ch, $f())
+    catch e
+        if !(e isa HTTPError)
+            e = CapturedException(e, catch_backtrace())
         end
+        close(ch, e)
+    finally
+        close(timer)
     end
     return take!(ch)
 end

src/clientlayers/StreamRequest.jl

@@ -33,15 +33,15 @@ function streamlayer(stream::Stream; iofunction=nothing, decompress::Union{Nothi
     try
         @sync begin
             if iofunction === nothing
-                @async try
+                Threads.@spawn try
                     writebody(stream, req)
                     @debugv 2 "client closewrite"
                     closewrite(stream)
                 finally
                     req.context[:write_duration_ms] = get(req.context, :write_duration_ms, 0.0) + ((time() - write_start) * 1000)
                 end
                 read_start = time()
-                @async try
+                Threads.@spawn try
                     @debugv 2 "client startread"
                     startread(stream)
                     if isaborted(stream)