File tree Expand file tree Collapse file tree 2 files changed +2
-4
lines changed Expand file tree Collapse file tree 2 files changed +2
-4
lines changed Original file line number Diff line number Diff line change @@ -53,7 +53,6 @@ def reader(task)
53
53
54
54
@head . close_write
55
55
rescue => error
56
- raise
57
56
ensure
58
57
@input . close ( error )
59
58
@@ -71,7 +70,6 @@ def writer(task)
71
70
@output . write ( chunk )
72
71
end
73
72
rescue => error
74
- raise
75
73
ensure
76
74
@output . close_write ( error )
77
75
Original file line number Diff line number Diff line change 143
143
end
144
144
ensure
145
145
Console . debug ( self ) { "Finished reading from upstream..." }
146
- stream . close_write
146
+ stream . close_write unless stream . closed?
147
147
end
148
148
149
149
writer = Async do |task |
155
155
end
156
156
ensure
157
157
Console . debug ( self ) { "Finished writing to upstream..." }
158
- upstream . close_write
158
+ upstream . close_write unless upstream . closed?
159
159
end
160
160
161
161
reader . wait
You can’t perform that action at this time.
0 commit comments