We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent c18a7c4 commit c050fc7Copy full SHA for c050fc7
2 files changed
lib/async/http/body/pipe.rb
@@ -53,7 +53,6 @@ def reader(task)
53
54
@head.close_write
55
rescue => error
56
- raise
57
ensure
58
@input.close(error)
59
@@ -71,7 +70,6 @@ def writer(task)
71
70
@output.write(chunk)
72
end
73
74
75
76
@output.close_write(error)
77
test/async/http/proxy.rb
@@ -143,7 +143,7 @@
143
144
145
Console.debug(self) {"Finished reading from upstream..."}
146
- stream.close_write
+ stream.close_write unless stream.closed?
147
148
149
writer = Async do |task|
@@ -155,7 +155,7 @@
155
156
157
Console.debug(self) {"Finished writing to upstream..."}
158
- upstream.close_write
+ upstream.close_write unless upstream.closed?
159
160
161
reader.wait
0 commit comments